我需要向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”}的头。
我如何做到这一点?
谢谢
暂无答案!
目前还没有任何答案,快来回答吧!