检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在左侧导航栏单击“Topic管理”，进入Topic列表页面。 在待生产消息的Topic所在行，单击“更多 > 生产消息”，弹出“生产消息”对话框。 参考表1，设置消息的相关参数。 表1 消息参数 参数名称 说明 消息内容 输入消息的内容。长度为0~128000B。 消息Key 输入消息的Key。
更多 > 到期转按需”。 勾选Kafka实例名称左侧的方框，可选一个或多个，单击信息栏左上侧的“更多 > 到期转按需”，弹出“到期转按需”对话框，单击“是”。 查看资费变更的相关信息，确认无误后单击“到期转按需”。 在费用中心转按需 进入“费用中心 > 续费管理”页面。 自定义查询条件。
查询消费组信息 当前页面API为历史版本API，未来可能停止维护。请使用查询消费组信息。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/groups/{group} 参数说明如下表所示。 表1 参数说明 参数 类型
@#$%^&*()-_=+\|[{}]:'",<.>/?和空格，并且不能以-开头。 非弱密码（如果不能确定哪些是弱密码，请在开启SSL双向认证对话框中输入密码，系统会自动判定是否为弱密码）。 按照提示信息输入证书拥有者的信息，包含姓名、单位、组织名称、所在城市、所在省、所在国家，示例如下。
创建转储任务 功能介绍 创建转储任务。 当前页面API为历史版本API，未来可能停止维护。请使用开启Smart Connect（按需实例）。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/connectors/{connector_id}/sink-tasks
例列表页面。 单击Kafka实例名称，进入“基本信息”页面。 在“实例信息”区域的“Kafka自动创建Topic”后，单击或，弹出“确认”对话框。 单击“确认”，完成“Kafka自动创建Topic”的开启/关闭。 您可以在“后台任务管理”页面，查看开启/关闭任务的执行状态。 父主题：
勾选Topic名称左侧的方框，可选一个或多个，单击信息栏左上侧的“编辑Topic”。 在待修改老化时间的Topic所在行，单击“编辑”。 在“编辑Topic”对话框中，输入老化时间，单击“确定”。 父主题： 管理消息
通过以下任意一种方法，实现按需实例转包周期。 勾选Kafka实例名称左侧的方框，可选一个或多个，单击信息栏左上侧的“转包周期”，弹出“转包周期”对话框，单击“是”，跳转到“按需转包年/包月”页面。 在待转包周期的Kafka实例所在行，单击“更多 > 转包周期”，跳转到“按需转包年/包月”页面。
单击Kafka实例的名称，进入实例详情页面。 在左侧导航栏选择“消费组管理”，进入消费组列表页面。 单击“创建消费组”，弹出“创建消费组”对话框。 参考表1设置消费组参数，单击“确定”。 表1 消费组参数说明 参数 说明 消费组名称 自定义名称，但需要符合命名规则：只能由英文字母、数字、下划线开头，且只能英文字母、
产品优势 分布式消息服务Kafka版完全兼容开源社区版本，旨在为用户提供便捷高效的消息队列。业务无需改动即可快速迁移上云，为您节省维护和使用成本。 一键式部署，免去集群搭建烦恼 您只需要在实例管理界面选好规格配置，提交订单。后台将自动创建部署完成一整套Kafka实例。 兼容开源，业务零改动迁移上云
勾选Topic名称左侧的方框，可选一个或多个，单击信息栏左上侧的“编辑Topic”。 在待修改配置的Topic所在行，单击“编辑”。 在“编辑Topic”对话框中，修改Topic的配置，单击“确定”。 当副本数为1时，不能开启同步复制功能。 开启同步复制后，需要在客户端配置acks=all或者-1，否则无效。
消息时通过CreateTime指定的，如果生产消息时没有设置此参数，创建时间会默认为1970。 单击“查看消息正文”，弹出“查看消息正文”对话框，查看消息的内容，包括Topic名称、分区、偏移量、创建时间和消息正文。 控制台只能展示4KB以内的消息，超过4KB的消息，请单击“下载消息”，下载到本地查看消息完整的内容。
在实例列表页面，单击实例名称，进入实例详情页。 在左侧导航栏单击“后台任务管理”，进入“后台任务”页签。 单击“任务名”为“变更规格”的任务，弹出“变更规格任务详情”对话框。 在顶部区域，查看变更进度和预计剩余时间。在“任务执行步骤”中，查看执行步骤的名称和开始执行时间，以及结束时间。 查看变更是否成功。
修改方法请参考配置Kafka实例的公网访问。 系统跳转到“后台任务管理”页面，并显示当前任务的操作进度和结果。 容量阈值策略 单击待选择的容量阈值策略，弹出“确认”对话框，单击“确定”。 修改容量阈值策略，不会重启实例。 磁盘使用量达到容量阈值时会触发对应的阈值处理策略，可能会导致消息被删除或无法继续生产消息。
在顶部搜索框中单击鼠标左键，选择“资源类型”，然后在下拉框中勾选“分布式消息服务”，单击“确定”。 在“分布式消息服务”所在行，按，弹出“开启告警规则”对话框。 Kafka实例包含2个预先设定的告警规则，详情参见表2，请根据实际需求开启对应的告警规则开关，单击“确定”。 图3 开启告警规则 表2
进度的Topic分区后，单击“重置消费进度”。 重置所有Topic所有分区的消费进度：单击“重置所有消费进度”。 在弹出的“重置消费进度”对话框中，参考表1，设置重置消费进度参数。 表1 重置消费进度参数说明 参数 说明 重置类型 选择重置类型： 时间：重置消费进度到指定的时间。
击页面左上角下拉框，选择时间段，在搜索对话框中输入待修改定时分区平衡任务的Topic名称，按“Enter”，实现快速查找定时分区平衡任务。 图5 查找定时分区平衡任务 在待修改的定时分区平衡任务后，单击“修改”。 在弹出的“修改定时任务”对话框中，您可以修改定时分区平衡任务的时间
在“公网NAT网关”页面，在新购买的公网NAT网关后，单击“设置规则”，进入公网NAT网关详情页。 在“DNAT规则”页签，单击“添加DNAT规则”，弹出“添加DNAT规则”对话框。 图3 公网NAT网关详情页 设置如下参数。 使用场景：选择“虚拟私有云” 端口类型：选择“具体端口” 支持协议：选择“TCP” 公网
单击Kafka实例的名称，进入实例的“基本信息”页面。 关闭公网访问前，需要先关闭公网访问中的“明文接入”和“密文接入”。然后在“公网访问”后，单击，弹出确认关闭对话框。 单击“确认”，跳转到“后台任务管理”页面。当任务状态显示为“成功”时，表示成功关闭公网访问。 关闭公网访问后，需要设置对应的安全组规
使用VPCEP实现跨VPC访问Kafka Kafka客户端和Kafka实例在同一区域的不同VPC中，由于VPC之间逻辑隔离，Kafka客户端和Kafka实例不能直接通信。您可以通过以下任意一个方式实现跨VPC访问： 创建VPC对等连接，将两个VPC的网络打通，实现跨VPC访问。具体步骤请参考对等连接。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
