☰

Kafkaコンソールプロデューサーでキーと値のメッセージを送信する方法 質問する

tag-icon • tag-icon apache-kafka kafka-consumer-api kafka-producer-api
Kafkaコンソールプロデューサーでキーと値のメッセージを送信する方法 質問する

Kafka コンソール プロデューサーを使用してキー値メッセージを送信する必要があるユースケースがあります。コマンドを使用してこれを実現するにはどうすればよいでしょうかkafka-console-producer?

ベストアンサー1

調査した後、解決策を見つけました。解決策はここにあります。

kafka-console-producer コマンド

kafka-console-producer.sh --broker-list localhost:9092 --topic topic-name --property "parse.key=true" --property "key.separator=:"

このコマンドを実行すると、プロデューサー コンソールに入り、そこからキーと値のメッセージを送信できるようになります。

例えば

key1:value1
key2:value2
key3:value3

より明確にするために、ここではサンプルのキーと値のメッセージを提供します。emp_infoはキーであり、JSON objectは値です。

emp_info: {"emp_id":100,"first_name":"Keshav","last_name":"Lodhi","designation":"DataEngineer"}

注記：単にテキスト行を送信すると、キーを含むメッセージが送信されますnull。キーを含むメッセージを送信するには、プロデューサーを実行するときにコマンド ラインでプロパティとプロパティをkeys and values設定する必要があります。parse.keykey.separator

おすすめ記事