3

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

我如何实现这一目标？

谢谢

4

0 回答 0