Нужен ли мне собственный сериализатор для создания сообщения JSON в kafka?

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

Теперь я хотел бы знать, нужен ли мне пользовательский сериализатор для создания сообщения в формате JSON в очереди, потому что в конце концов сообщение JSON будет простой строкой.


apache-kafka json
person JavaTechnical    schedule 19.01.2015    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Я думаю, что да, вам нужно реализовать свой собственный сериализатор по умолчанию. По умолчанию класс сериализатора String поставляется вместе с Kafka. Вам нужно внедрить класс Encoder<T>, а затем переопределить метод toBytes(..).

Вот хороший пост, в котором рассказывается о реализации аналогичного пользовательского сериализатора.

person user2720864    schedule 20.01.2015
comment
Я не понимаю - зачем нужен специальный сериализатор для создания кафки? На стороне потребителя может потребоваться инкапсулировать логику преобразования сообщения JSON из kafka в любой объект домена, необходимый приложению. Я что-то упускаю ? - person Abhishek; 18.05.2017