kafkacat从带有头的文件生成消息

u5i3ibmn  于 2021-06-05  发布在  Kafka
关注(0)|答案(0)|浏览(307)

我需要向kafka生成批处理消息,这样我就有了一个文件供kafkacat使用:

kafkacat -b localhost:9092 -t <my_topic> -T -P -l /tmp/msgs

/tmp/msgs的内容如下

-H "id=1"
{"key" : "value0"}
-H "id=2"
{"key" : "value1"}

当我运行上面的kafkacat命令时,它会向kafka插入四条消息/tmp/msgs中的每行一条消息。
我需要指示kafkacat正确解析文件-即-h“id=1”是消息{“key”=“value0”}的头。
我如何做到这一点?
谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题