云服务器内容精选

华为云首页用户手册

管理消费组

分布式消息服务KAFKA版-删除Kafka消费组:约束与限制

约束与限制若“auto.create.groups.enable”设置为“true”，当消费组的状态为“EMPTY”且从未提交过offset，系统将在十分钟后自动删除该消费组。若“auto.create.groups.enable”设置为“false”，系统不会自动删除消费组。如果需要删除消费组，需要您手动删除。若消费组从未提交过offset，当Kafka实例重启后，该消费组会被删除。删除消费组会导致消费进度丢失，造成重新消费或重复消费等情况。

分布式消息服务KAFKA版管理消费组
分布式消息服务KAFKA版-查看Kafka消费者信息:查看消费者连接地址（Kafka Manager）

查看消费者连接地址（Kafka Manager）登录Kafka Manager。单击“kafka_cluster”，进入集群详情页。在顶部导航栏单击“Consumers”，进入消费组列表页面。图2 导航栏单击待查看消费者连接地址的消费组名称，进入消费组订阅的Topic列表页面。图3 消费组列表页面单击待查看消费者连接地址的Topic名称，进入Topic详情页。图4 消费组订阅的Topic列表页面在“Consumer Instance Owner”中，查看消费者连接地址。图5 Topic详情页

分布式消息服务KAFKA版管理消费组
分布式消息服务KAFKA版-查看和重置Kafka消费进度:查看消费进度（Kafka客户端）

查看消费进度（Kafka客户端）未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令查询消费进度。 ./kafka-consumer-groups.sh --bootstrap-server ${connection-address} --offsets --describe --all-groups 已开启密文接入的Kafka实例，通过以下步骤查询消费进度。（可选）Kafka安全协议为“SASL_PLAINTEXT”还是“SASL_SSL”？ SASL_PLAINTEXT：如果已经设置了用户名和密码，请跳过此步骤。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考3增加用户名和密码。 SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考3增加用户名和密码，以及SSL证书配置。在Kafka客户端的“/bin”目录下，通过以下命令查询消费进度。 ./kafka-consumer-groups.sh --bootstrap-server ${connection-address} --offsets --describe --all-groups --command-config ./config/ssl-user-config.properties

分布式消息服务KAFKA版管理消费组