apache-kafka - 删除未使用的 kafka 消费者组

Question

我正在使用 Confluent / Apache Kafka 0.10将主题压缩为 分布式缓存同步机制 .当应用程序启动时，它会生成一个特定于实例的 consumer group id .随着为水平可扩展性添加和删除实例，显然我们得到了大量不应再次使用的组 ID。

我确信这是 KStreams 的完美用例和 KTables ，但出于智力原因以及 KStreams，我正试图自己做这件事。和 KTables被定义为 0.10 中的 alpha 质量。

有没有Kafka API我可以使用的调用可以删除现有的 consumer group ，知道它不应该再次使用？

自 Zookeeper未在 version 0.10 中维护消费者抵消, 有没有办法删除consumer group使用 Kafka ?

Answer 1

It's possible with CLI in Kafka

./bin/kafka-consumer-groups \
    --bootstrap-server <bootstrap_server(s)> \
    --topic <topic_name> \
    --delete \
    --group <consumer_group_name> 

kafka-consumer-groups应该在 Kafka 安装主页中可用。