Как отправлять сообщения о ключах и значениях с производителем консоли kafka - PullRequest
Новая
       112

Как отправлять сообщения о ключах и значениях с производителем консоли kafka

2 голосов
/ 28 мая 2020

У меня есть пример использования, когда мне нужно отправлять сообщения о ключевом значении с помощью Kafka Console Producer. Итак, как этого добиться с помощью команды Kafka Console Producer?

1 Ответ

6 голосов
/ 28 мая 2020

Я нашел решение после некоторого исследования, и решение здесь.

команда kafka-console-производителя 

kafka-console-producer.sh --broker-list localhost:9092 --topic topic-name --property "parse.key=true" --property "key.separator=:"

После выполнения этой команды вы войдете в консоль производителя и оттуда сможете отправлять сообщения о ключах и значениях.

Например, 

key1:value1
key2:value2
key3:value3

Для большей ясности я предоставляю образец сообщения «ключ-значение» здесь emp_info - это ключ, а JSON object - значение. 

emp_info: {"emp_id":100,"first_name":"Keshav","last_name":"Lodhi","designation":"DataEngineer"}

Примечание: Простая отправка строк текста приведет к сообщениям с null ключами. Чтобы отправлять сообщения с обоими keys and values, вы должны установить свойства parse.key и key.separator в командной строке при запуске производителя.

...