Отправка Всего Json на кафку с авро сериализацией?

Question

У меня есть файл json, и я хочу отправить его содержимое потребителю Kafka. Кафка использует Avro и схему, которая соответствует Json, которую я хочу отправить. Так есть способ прочитать json, а затем отправить все его содержимое через kafka без необходимости сначала анализировать json а потом отправлять все отдельно с ключами и значениями?

Спасибо.

Answer 1

Предполагая, что вы используете реестр схем, вы можете удалить пробел из файла, а затем прочитать его как stdin

kafka-avro-console-consumer  ... < $(cat file.json)

В противном случае вам потребуется написать собственного производителя, чтобы иметь возможность Плагин Авро сериализатор