【发布时间】:2021-06-14 11:53:43
【问题描述】:
刚接触卡夫卡。
今天我在运行kafka-console-producer.sh的一些命令,我正在使用键值对消息
bin/kafka-console-producer.sh --topic producer-demo --property "parse.key=true" --property "key.separator=:" --broker-list kafka1:9092
我只是好奇在哪里可以找到像我搜索的生产者属性**"parse.key=true"** 和**"key.separator=:"** in
https://kafka.apache.org/documentation/#producerconfigs
没有像这样的参数是这个自定义参数或预定义的,因为我必须更多地使用它,我可以应用在这个命令上
【问题讨论】:
-
你的 kafka 客户端是什么?
-
基本上没有这样的客户端我正在测试这个我想使用 bin/kafka-console-producer.sh --topic producer-demo --property "parse 在同一分区中发送生产者消息.key=true" --property "key.separator=:" --property "partition=1" --broker-list kafka1:9092 但我没有解决我的问题是 parse.key 和 key.separator定义了这些参数,以便我可以学习并做一些实际操作
标签: apache-kafka