apache-kafka - 未使用のカフカ コンシューマー グループを削除する

Question

Apache Kafka 0.10 をコンパクトなトピックと共に分散キャッシュ同期メカニズムとして使用しています。アプリケーションが起動すると、インスタンス固有のconsumer group id. 水平方向のスケーラビリティのためにインスタンスが追加および削除されると、明らかに、二度と使用してはならない多数のグループ ID が取得されます。

KStreamsこれは と の完璧な使用例であると確信していますが、とが 0.10 でアルファ品質として定義されKTablesていることと同様に、知的な理由からこれを自分でやろうとしています。KStreamsKTables

既存のコンシューマー グループを削除できる、使用できる Kafka API 呼び出しはありますか?

Zookeeper はバージョン 0.10 でコンシューマー オフセットを維持していないため、Kafka を使用してコンシューマー グループを削除する方法はありますか?

Answer 1

KafkaのCLIで可能です

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

kafka-consumer-groupsKafka インストール ホームで利用できるはずです。