kafka + 如何删除消费者组

Question

在我们的kafka集群中（基于HDP版本-2.6.5，kafka版本为1.0），我们要删除如下消费者组

/usr/hdp/2.6.5.0-292/kafka/bin/kafka-consumer-groups.sh  --list --bootstrap-server kafka01:6667| grep -i test
Note: This will not show information about old Zookeeper-based consumers.

test_group_0e1e37b0-603e-4ffd-9b21-90a3adf597ca

但是当我们尝试删除它时，我们得到：

/usr/hdp/2.6.5.0-292/kafka/bin/kafka-consumer-groups.sh --zookeeper zookeeper01:2181 --delete --group test_group_0e1e37b0-603e-4ffd-9b21-90a3adf597ca
To enable GC log rotation, use -Xloggc:<filename> -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=<num_of_files>
where num_of_file > 0
GC log rotation is turned off
Note: This will only show information about consumers that use ZooKeeper (not those using the Java consumer API).

Error: Delete for group 'test_group_0e1e37b0-603e-4ffd-9b21-90a3adf597ca' failed because group does not exist.

以上命令有什么问题？

来自 Kafka Ambari 配置的更多详细信息：

Answer 1

如输出所示，--zookeeper

组不存在

你需要保持你的论点一致；使用 --bootstrap-server 来列出、删除和描述，假设您的集群支持此

但是，组会在没有活跃消费者的情况下自行删除，因此您不需要运行这个

kafka + 如何删除消费者组

kafka + how to delete consumer group

producer-consumer

apache-kafka

kafka-consumer-api