文章来源:如何删除Kafka消费组_分布式消息服务Kafka版_常见问题_消费组问题_华为云
Kafka消费组可以通过Kafka客户端的命令行方式连接Kafka实例完成删除。
说明:
请下载与Kafka实例版本相同的客户端。
- 查询消费组
kafka-consumer-groups.sh –bootstrap-server {kafka连接地址} –list
[root@zk-server-1 bin]# ./kafka-consumer-groups.sh --bootstrap-server 172.31.1.245:9091,172.31.1.86:9091,172.31.1.128:9091 --list Note: This will not show information about old Zookeeper-based consumers. KMOffsetCache-zk-server-1 bbbb KMOffsetCache-zk-server-0
- 查询消费组详情
kafka-consumer-groups.sh –bootstrap-server {kafka连接地址} –describe –group {消费组}
[root@zk-server-1 bin]# ./kafka-consumer-groups.sh --bootstrap-server 172.31.1.245:9091,172.31.1.86:9091,172.31.1.128:9091 --describe --group bbbb Note: This will not show information about old Zookeeper-based consumers. Consumer group 'bbbb' has no active members. TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID test 1 336 336 0 - - - test 0 334 334 0 - - - test 2 334 334 0 - - -
- 删除消费组
kafka-consumer-groups.sh –bootstrap-server {kafka连接地址} –delete –group {消费组}
[root@zk-server-1 bin]# ./kafka-consumer-groups.sh --bootstrap-server 172.31.1.245:9091,172.31.1.86:9091,172.31.1.128:9091 --delete --group bbbb Note: This will not show information about old Zookeeper-based consumers. Deletion of requested consumer groups ('bbbb') was successful.
说明:
- 如果Kafka实例开启SASL认证,则以上命令还需要增加SASL认证的“consumer.properties”配置文件参数: –command-config {SASL认证的consumer.properties配置文件},“consumer.properties”配置文件参考开启SASL认证的Kafka命令行连接说明。
- Kafka客户端环境配置,请参考未开启SASL认证的Kafka命令行连接说明、开启SASL认证的Kafka命令行连接说明。