You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by ankit tyagi <an...@gmail.com> on 2015/02/25 13:54:13 UTC

custom serializer and deserializer

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.

Re: custom serializer and deserializer

Posted by Guozhang Wang <wa...@gmail.com>.

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 <an...@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