Re: How to send serialized object in Kafka Producer

[Guozhang Wang]

You need to write your own serializer (e.g. BeanSerializer extends
Encoder[T]) for bean object and specify that in:

properties.put("serializer.class","BeanSerializer")


Guozhang