Only the consumer needs deserializer classes. The current Java consumer is
still under development but when it is finished you will find the
corresponding KEY_DESERIALIZER_CLASS_CONFIG /
VALUE_DESERIALIZER_CLASS_CONFIG in ConsumerConfig.
Guozhang
On Wed, Feb 25, 2015 at 4:54 AM, ankit tyagi
wrot
Hi,
I want to use protobuff for serializing and deserializing kafkaevents in
.8.2.0. I can provide my custom serializer by
setting KEY_SERIALIZER_CLASS_CONFIG and VALUE_SERIALIZER_CLASS_CONFIG.
but how can I provide custom Deserializer.
