どのようにしてKafkaの生成メッセージを確認するのか

Kafka の作成メッセージを確認するには、Kafka のコマンドラインツールを使用してメッセージの詳細を確認できます。以下はよく使用されるコマンドラインツールとコマンドです。

  1. kafka-console-consumerユーティリティを使用してメッセージを表示します。
  2. kafka-console-consumer.sh –bootstrap-server <kafkaサーバーアドレス:ポート> –topic <トピック名称> –from-beginning
  3. このコマンドは、指定されたトピックからメッセージの消費を開始し、コンソールにメッセージを出力します。
  4. メッセージの詳細(オフセット、パーティション、タイムスタンプなど)を確認したい場合は、以下を実行してください:
  5. kafka-console-consumer.sh –bootstrap-server <kafkaサーバーアドレス:ポート> –topic <トピック名> –from-beginning –property print.key=true –property print.timestamp=true
  6. このコマンドはメッセージのオフセット、パーティション、キーおよびタイムスタンプといった詳細情報をプリントします。
  7. :kafka-console-consumerツールを用いて、コンシューマグループを指定する場合
  8. kafka-console-consumer.sh –bootstrap-server <Kafkaサーバーアドレス:ポート> –topic <トピック名> –from-beginning –consumer-property group.id=<コンシューマーグループID>
  9. このコマンドは、指定されたコンシュマーグループを使ってメッセージを消費します。

コマンドツール以外で作成されたメッセージを見る場合は、Kafka の API を利用し、独自のプログラムを作成することもできます。Kafka の Java または他の言語のクライアントライブラリを使用すると、メッセージを消費し、詳しい情報のメッセージを取得できます。

bannerAds