どのようにしてKafkaの生成メッセージを確認するのか
Kafka の作成メッセージを確認するには、Kafka のコマンドラインツールを使用してメッセージの詳細を確認できます。以下はよく使用されるコマンドラインツールとコマンドです。
- kafka-console-consumerユーティリティを使用してメッセージを表示します。
- kafka-console-consumer.sh –bootstrap-server <kafkaサーバーアドレス:ポート> –topic <トピック名称> –from-beginning
- このコマンドは、指定されたトピックからメッセージの消費を開始し、コンソールにメッセージを出力します。
- メッセージの詳細(オフセット、パーティション、タイムスタンプなど)を確認したい場合は、以下を実行してください:
- kafka-console-consumer.sh –bootstrap-server <kafkaサーバーアドレス:ポート> –topic <トピック名> –from-beginning –property print.key=true –property print.timestamp=true
- このコマンドはメッセージのオフセット、パーティション、キーおよびタイムスタンプといった詳細情報をプリントします。
- :kafka-console-consumerツールを用いて、コンシューマグループを指定する場合
- kafka-console-consumer.sh –bootstrap-server <Kafkaサーバーアドレス:ポート> –topic <トピック名> –from-beginning –consumer-property group.id=<コンシューマーグループID>
- このコマンドは、指定されたコンシュマーグループを使ってメッセージを消費します。
コマンドツール以外で作成されたメッセージを見る場合は、Kafka の API を利用し、独自のプログラムを作成することもできます。Kafka の Java または他の言語のクライアントライブラリを使用すると、メッセージを消費し、詳しい情報のメッセージを取得できます。