如何通过kafka控制台生产者发送密钥,价值消息
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了如何通过kafka控制台生产者发送密钥,价值消息相关的知识,希望对你有一定的参考价值。
我有一个用例,需要用Kafka Console Producer发送键值消息。那么如何通过Kafka Console Producer
命令来实现呢?
答案
我经过研究后找到了解决方案,解决方案在这里。
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.key
和key.separator
属性。
以上是关于如何通过kafka控制台生产者发送密钥,价值消息的主要内容,如果未能解决你的问题,请参考以下文章