apache-zookeeper - 删除zookeeper中的kafka消费者组

Question

我正在使用 kafka_2.9.2-0.8.1.1 和 Zookeeper 3.4.6。

是否有一个实用程序可以自动从zookeeper中删除消费者组？或者我可以删除 Zookeeper 中/consumers/[group_id] 下的所有内容吗？如果是后者，我还缺少什么吗？这可以通过实时系统来完成吗？

更新:从 kafka 2.3.0 版本开始，有一个新的实用程序:

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


相关文档:http://kafka.apache.org/documentation/#basic_ops_consumer_lag

更多讨论见下文

Answer 1

从 v0.9.0 开始，Kafka 在 /bin 中附带了一套工具。其中之一是kafka-consumer-groups.sh工具。这将删除一个消费者组。 ./kafka-consumer-groups.sh --zookeeper <zookeeper_url> --delete --group <group-name>