apache-kafka - 如何删除 Kafka Consumer Group 以重置偏移量？

Question

我想删除一个 Kakfa 消费者组，以便应用程序创建消费者并订阅主题时，它可以从主题数据的开头开始。

这是使用当前最新的 Confluence Platform 3.1.2(使用 Kafka 0.10.1.1)的单节点开发虚拟机。

我尝试正常的语法:

sudo /usr/bin/kafka-consumer-groups --new-consumer --bootstrap-server localhost:9092 --delete --group my_consumer_group

我收到错误:

Option [delete] is only valid with [zookeeper]. Note that there's no need to delete group metadata for the new consumer as the group is deleted when the last committed offset for that group expires.

如果我尝试动物园管理员变体:

sudo /usr/bin/kafka-consumer-groups --zookeeper localhost:2181 --delete --group my_consumer_group

我得到:

Delete for group my_consumer_group failed because group does not exist.

如果我使用“旧”消费者列出，我看不到我的消费者组(或任何其他消费者组)

sudo /usr/bin/kafka-consumer-groups --zookeeper localhost:2181 --list

如果我使用"new"消费者列出，我可以看到我的消费者组，但显然我无法删除它:

sudo /usr/bin/kafka-consumer-groups --new-consumer --bootstrap-server localhost:9092 --list

Answer 1

这可以通过 Kafka 1.1.x 来完成。来自文档:

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group my-group --group my-other-group