Apache Kafka：トピックの消費者グループを見つける方法

Question

私はScalaでSparkストリーミングを使用してKafkaに取り組んでいます。私はメッセージを取得する必要がある複数のトピックがあります。そのためには、各トピックの消費者グループを入力する必要があります。

私は以下のコマンドを試してみました。このため

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group group_name 

を、私は消費者のグループに言及し、私のトピックは、このグループに該当するかどうかを確認する必要があります。しかし、私はいくつかのトピックの消費者グループの価値を知らない。

したがって、には、特定のトピックのコンシューマ・グループを見つけるためのコマンドまたはプログラム的な方法がありますか？

これに関するお手伝いがあれば幸いです。 ありがとうございます

Answer 1

トピックを指定することによって、さまざまなトピックからデータを読み取ることができます。トピックのマップを作成するだけです。指定されたトピックから消費する消費者団体を一覧表示するカフカではありません。コマンド/ APIはありませんが、下のリンク

https://www.tutorialspoint.com/apache_kafka/apache_kafka_consumer_group_example.htm

Answer 2

を参照してください。代わりにyahooによって開発されたツールを使用して、kafkaクラスタを管理することができます：Yahoo Kafka Manager。このソフトウェアをインストールし、yahoo kafkaマネージャーをカフカクラスターに向けると、指定したトピックから消費する消費者グループを表示できます。