Я пытаюсь построить POC с Kafka 0.8.1. Я использую свой собственный класс Java в качестве сообщения Kafka, которое имеет кучу типов данных String. Я не могу использовать класс сериализатора по умолчанию или класс сериализатора String, который поставляется с библиотекой Kafka. Я думаю, мне нужно написать свой собственный сериализатор и передать его в свойствах производителя. Если вы знаете, как написать пример настраиваемого сериализатора на Kafka (на Java), пожалуйста, поделитесь. Ценю большое, большое спасибо.