Есть ли способ добавить заголовки в kafka-console-producer.sh

Question

Я бы хотел использовать kafka-console-producer.sh для запуска нескольких сообщений JSON с заголовками Kafka.

Возможно ли это?

docker exec -it kafka_1 /opt/kafka_2.12-2.3.0/bin/kafka-console-producer.sh --broker-list localhost:9093 --topic my-topic --producer.config /opt/kafka_2.12-2.3.0/config/my-custom.properties

Answer 1

Нет, но вы можете использовать аргумент kafkacat -H:

Производить:

echo {"col_foo":1}|kafkacat -b localhost:9092 -t test -P -H foo=bar

Потреблять:

kafkacat -b localhost:9092 -t test -C -f '-----\nTopic %t[%p]\nOffset: %o\nHeaders: %h\nKey: %k\nPayload (%S bytes): %s\n'
-----
Topic test[0]
Offset: 0
Headers: foo=bar
Key:
Payload (9 bytes): col_foo:1
% Reached end of topic test [0] at offset 1