Kafkaのコンシューマーグループをどのように確認できますか?
Kafkaのコンシューマグループを確認するには、Kafkaの組み込みのコマンドラインツールを使用するか、プログラミング言語のKafkaクライアントを使用して操作することができます。
コマンドラインツールを使用して消費グループを確認してください。
- ターミナルを開き、Kafkaのインストールディレクトリのbinディレクトリに移動してください。
- 上記のコマンドを入力してください:./kafka-consumer-groups.sh –bootstrap-server <kafkaサーバーのアドレス:ポート番号> –list
このコマンドは、すべてのコンシューマーグループをリストアップします。
プログラミング言語を使用したKafkaクライアントで消費者グループを確認します。
- Kafkaクライアントライブラリを導入しましょう。例えば、Javaのkafka-clientsライブラリを使用します。
- KafkaConsumerオブジェクトを作成し、関連するパラメータを設定します。
- consumer.listGroups()メソッドを呼び出すと、すべての消費グループ情報が含まれたConsumerGroupListingオブジェクトのコレクションが返されます。
- ConsumerGroupListingのコレクションを走査すると、各消費グループの詳細情報(消費グループID、消費者数など)を取得できます。
上記の方法を実行する際に注意する必要があるのは、Kafkaサーバーが稼働していて、対応するコンシューマーグループがすでに設定されていることです。