Производитель приставок Kafka JSON

Question

Я пытаюсь использовать производителя консоли Kafka, kafka-console-producer.Кажется, что по умолчанию используется строковый сериализатор.

Можно ли настроить производитель консоли Kafka на использование сериализатора JSON?

Answer 1

Я просто хотел добавить, в дополнение к тому факту, что StringSerializer используется по умолчанию, вы можете выбрать любой сериализатор, который вам нужен (даже пользовательские реализации), указав имена классов в следующих конфигурациях производителя:

key.serializer
value.serializer

Тогда вашим потребителям потребуется использовать соответствующий десериализатор, и вы установите его в следующих конфигурациях потребителя:

key.deserializer
value.deserializer

Документация Apache Kafka

Отредактировано: AtСначала я подумал, что класс сериализатора имеет значение по умолчанию, но это не так в соответствии с документацией Kafka.Он может быть установлен в соответствии с типом данных, используемым для ваших пар ключей и значений в создаваемой записи.В любом случае, это будут параметры, которые вам нужно настроить для установки определенного класса с реализацией необходимого вам сериализатора / десериализатора.

Answer 2

Сериализатор JSON является просто расширением сериализованного String;он также принимает необработанный строковый объект и преобразует его в байты.Кроме того, простые строки являются допустимыми типами JSON.

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