apache-kafka - 如何使用kafka控制台生产者发送关键，有值(value)的消息

Question

我有一个用例，需要通过Kafka Console Producer发送键值消息。那么如何通过Kafka Console Producer命令实现这一目标呢？

Answer 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.key和 key.separator属性。