[解決済み] Kafkaコンシューマーリスト

質問

Kafkaにトピックのリストを問い合わせる方法を探しています。私は、私がそれを行うことができます知っている kafka-topics.sh スクリプトを使用することです。 bin\ ディレクトリにあります。このリストができたら、トピックごとにすべてのコンシューマが必要です。そのディレクトリにスクリプトは見つかりませんでしたし、クラスも kafka-consumer-api ライブラリにも、それを可能にするクラスは見つかりませんでした。

この背後にある理由は、トピックのオフセットと消費者のオフセットの違いを把握する必要があるからです。

これを実現する方法はありますか? それとも、各コンシューマーにこの機能を実装する必要があるのでしょうか?

どのように解決するのですか？

kafka-consumer-groups.sh を使用します。

例えば

bin/kafka-consumer-groups.sh  --list --bootstrap-server localhost:9092

bin/kafka-consumer-groups.sh --describe --group mygroup --bootstrap-server localhost:9092