kafka + 如何删除消费者组

kafka + how to delete consumer group

在我们的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 配置的更多详细信息:

如输出所示,--zookeeper

组不存在

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

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