Мне нужно создать пакетные сообщения для 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"}.
Как мне этого добиться?
Спасибо