我正在使用 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 http://kafka.apache.org/documentation/#basic_ops_consumer_lag
请参阅下文了解更多讨论
从 v0.9.0 开始，Kafka 附带了一套工具/bin其中之一是kafka-consumer-groups.sh工具。这将删除一个消费者组。./kafka-consumer-groups.sh --zookeeper <zookeeper_url> --delete --group <group-name>
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
