Kafkaに残っているメッセージ数を確認するには、どうすればいいですか?

Kafkaの残りメッセージ数を確認するには、以下の方法のうち一つを使用できます:

  1. Kafkaのデフォルトのコマンドラインツールを使用して、消費者グループ内の残りのメッセージ数を確認することができます。以下のコマンドを実行してください:kafka-consumer-groups.sh。
  2. kafka-consumer-groups.sh –bootstrap-server <ブートストラップサーバー> –describe –group <コンシューマーグループ>
  3. 上記では、はKafkaクラスタの起動サーバーアドレスであり、は表示したい消費者グループの名前です。コマンドを実行すると、各パーティションの現在のオフセットや残りのメッセージ数など、消費者グループに関する詳細情報が表示されます。
  4. Kafkaを管理ツールで使用する場合、たとえばKafka ManagerやConfluent Control Centerを利用している場合、これらのツールのユーザーインターフェースで消費者グループの残りメッセージ数を確認できます。
  5. Kafkaのプログラムクライアントを使用する:Kafkaクラスタにプログラムで接続し、JavaやPythonのKafkaクライアントなどのKafkaプログラムクライアントを使用している場合、クライアントが提供するAPIを使用して、消費者グループの残りのメッセージ数を照会することができます。具体的な方法やコードは、使用しているクライアントライブラリによって異なる可能性がありますので、対応するドキュメントやサンプルコードを参照して実装してください。

各パーティションごとの現在の消費者グループのオフセットを基準として、残りのメッセージ数が該当しており、トピック全体のメッセージ数ではありません。

bannerAds