kafka + 如何删除消费组答案

【问题标题】：kafka + how to delete consumer groupkafka + 如何删除消费组
【发布时间】：2022-02-22 22:22:04
【问题描述】：

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

【问题讨论】：

标签： apache-kafka kafka-consumer-api producer-consumer

【解决方案1】：

正如输出所说，--zookeeper 不存在组

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

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

【讨论】：

但如果我使用 bootstarp-server 我得到：
选项 '[delete]' 仅对 '[zookeeper]' 有效。请注意，无需删除新使用者的组元数据，因为该组在该组的最后提交偏移量到期时被删除。
示例：我使用 /usr/hdp/2.6.5.0-292/kafka/bin/kafka-consumer-groups.sh --bootstrap-server kafka01:6667,kafka02:6667:kafka03:6667 --delete --group ...
或/usr/hdp/2.6.5.0-292/kafka/bin/kafka-consumer-groups.sh --bootstrap-server kafka01:6667 --delete --group
所以两个选项都没有成功