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