Kafkacat从带有标题的文件中生成消息。

Question

我需要为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"}的标题。

我怎样才能做到这一点？

谢谢

Answer 1

您需要按以下方式传递标头。

kcat -b localhost:9092 -t topic-name -P -H key1=value1 -H key2=value2 /temp/payload.json