检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在客户端修改Topic分区数 约束与限制 分区数只支持增加，不支持减少。 2023年5月17日及以后创建的实例不提供Kafka Manager功能，不支持在Kafka Manager中修改Topic分区数。 Kafka单机/集群实例对Topic的总分区数设置了上限，当Topic的总分
askFailure 删除后台任务成功 kafka deleteDMSBackendJobSuccess 删除后台任务失败 kafka deleteDMSBackendJobFailure 开启Smart Connect任务执行成功 kafka createConnectorTaskSuccess
如果您忘记了创建实例时设置的Kafka Manager密码，通过重置Manager密码功能，重新设置一个新的密码，可使用新密码登录Kafka Manager。 2023年5月17日及以后创建的实例不提供重置Kafka Manager密码功能。 前提条件 已创建Kafka实例，且实例处于“运行中”。 重置Kafka
置生产流控为50MB/s，待稳定后再修改为25MB/s，直到目标流控值。 前提条件 如果需要对用户进行流量控制，请在Kafka详情页开启密文接入功能。然后在控制台的“用户管理”页面，获取用户名。 如果需要对指定客户端进行流量控制，请在客户端配置中获取client ID。 如果需要
下文以topic-logstash为例介绍。 Kafka实例未开启公网访问、已开启SASL认证时，获取表3所示信息。 表3 Kafka实例信息（未开启公网访问、已开启SASL认证） 参数名 获取途径 内网连接地址 在Kafka实例详情页的“连接信息”区域，获取“内网连接地址”。 开启的SASL认证机制 在Kafk
查询所有消费组 功能介绍 查询所有消费组。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/{project_id}/instances/{instance_id}/groups 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String
公网访问Kafka实例的连接地址（公网连接地址） 图4 公网访问Kafka实例的连接地址（公网明文连接地址） 如果Kafka实例未开启自动创建Topic功能，在连接实例前，请先创建Topic，否则会连接失败。 已下载Kafka命令行工具1.1.0版本或者Kafka命令行工具2.3.0版本或者Kafka命令行工具2
果未及时处理，则产生告警通知。 图1 设置告警策略 设置“发送通知”开关。 当开启时，设置通知方式和不同方式对应的通知参数。 单击“立即创建”，等待创建告警规则成功。 开启一键告警 以下步骤指导您开启同一Region中所有Kafka实例关键指标的告警规则。 登录管理控制台。 在管
否 String 转储地址，即存储Topic数据的OBS桶的名称。（仅目标端类型为OBS时需要填写） obs_path 否 String 转储目录，即OBS中存储Topic的目录，多级目录可以用“/”进行分隔。（仅目标端类型为OBS时需要填写） partition_format 否
查询指定消费组 功能介绍 查询指定消费组。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 engine
在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能，降低您使用SDK的难度，推荐使用。 SDK列表 在开始使用之前，请确保您安装的是最新版本的SDK。使用过时的版本可能会导致兼容性问题或无法使用最新功能。您可以在SDK中心查询版本信息。 表1提供了分布式消息服务K
DEAD：消费组内没有任何成员，且没有任何元数据。 EMPTY：消费组内没有任何成员，存在元数据。 PREPARING_REBALANCE：准备开启Rebalance。 COMPLETING_REBALANCE：所有成员加入消费组。 STABLE：消费组内成员可以正常消费。 图1 消费组列表
令查看消费组中每个Topic的堆积消息数。“LAG”表示每个Topic的总堆积数。 图1 查看每个Topic的总堆积数 如果Kafka实例开启SASL认证，则以上命令还需要增加SASL认证的“consumer.properties”配置文件参数： --command-config
最新动态（html） 本文介绍了Huawei Cloud EulerOS产品新特性和对应的文档动态，新特性将在各个区域（Region）陆续发布，欢迎体验。
支持变更实例规格。 支持变更实例规格。 回收站中实例是否计费 开启回收站策略的包年/包月实例，退订后会存入回收站中，此时不收取实例费用，但是会按需收取存储空间费用。 从回收站中恢复的包年/包月实例，计费模式会变为按需计费。 开启回收站策略的按需实例，删除后会存入回收站中，此时不收取实例费用，按需收取存储空间费用。
”。 弹出“删除消费组”对话框，单击“确定”，完成消费组的删除。 使用命令行工具删除消费组 以下操作命令以Linux系统为例进行说明： 未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令删除消费组。 ./kafka-consumer-groups
制。在Kafka实例控制台的基本信息页面中获取。如果SCRAM-SHA-512和PLAIN都开启了，根据实际情况选择其中任意一种配置连接。很久前创建的Kafka实例在详情页如果未显示“开启的SASL认证机制”，默认使用PLAIN机制。 security_protocol：Kafk
只适用体验和业务测试场景，无法保证性能和可靠性。如果需要在生产环境使用Kafka实例，建议购买集群实例。 单机实例和集群实例支持的特性和功能有部分差异，具体如表1所示。 表1 单机实例和集群实例的差异说明 对比项 单机实例 集群实例 版本 支持2.7版本。 支持1.1.0、2.7和3
mechanism：SASL认证机制。在Kafka实例控制台的基本信息页面中获取。如果SCRAM-SHA-512和PLAIN都开启了，根据实际情况选择其中任意一种配置连接。很久前创建的Kafka实例在详情页如果未显示“开启的SASL认证机制”，默认使用PLAIN机制。 非SASL认证方式 package main
Manager，使Kafka Manager恢复正常。 图1 报错信息 2023年5月17日及以后创建的实例不提供重启Kafka Manager功能。 约束与限制 重启Kafka Manager不会影响业务。 重启Kafka Manager 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
