Kafkaのコンシューマーグループをどのように確認できますか?

Kafkaのコンシューマグループを確認するには、Kafkaの組み込みのコマンドラインツールを使用するか、プログラミング言語のKafkaクライアントを使用して操作することができます。

コマンドラインツールを使用して消費グループを確認してください。

  1. ターミナルを開き、Kafkaのインストールディレクトリのbinディレクトリに移動してください。
  2. 上記のコマンドを入力してください:./kafka-consumer-groups.sh –bootstrap-server <kafkaサーバーのアドレス:ポート番号> –list
    このコマンドは、すべてのコンシューマーグループをリストアップします。

プログラミング言語を使用したKafkaクライアントで消費者グループを確認します。

  1. Kafkaクライアントライブラリを導入しましょう。例えば、Javaのkafka-clientsライブラリを使用します。
  2. KafkaConsumerオブジェクトを作成し、関連するパラメータを設定します。
  3. consumer.listGroups()メソッドを呼び出すと、すべての消費グループ情報が含まれたConsumerGroupListingオブジェクトのコレクションが返されます。
  4. ConsumerGroupListingのコレクションを走査すると、各消費グループの詳細情報(消費グループID、消費者数など)を取得できます。

上記の方法を実行する際に注意する必要があるのは、Kafkaサーバーが稼働していて、対応するコンシューマーグループがすでに設定されていることです。

bannerAds