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 <ankittyagi.mn...@gmail.com> wrote: > 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. > -- -- Guozhang
