Decoder returns type T, which is not part of the java signature. I guess that we were not sure how to do reflection with generic support.
Thanks, Jun On Wed, Nov 7, 2012 at 11:28 AM, Hussein Baghdadi <hubaghd...@hotmail.com>wrote: > Why decoder isn't set in section "Consumer Code" ? > http://incubator.apache.org/kafka/quickstart.html > > > Date: Tue, 6 Nov 2012 06:54:13 -0800 > > Subject: Re: When the consumer needs the decoder? > > From: jun...@gmail.com > > To: kafka-users@incubator.apache.org > > > > > When you call createMessageStreams() in ConsumerConnector, you can pass > in > > a decoder. > > > > Thanks, > > > > Jun > > > > On Tue, Nov 6, 2012 at 4:24 AM, Hussein Baghdadi <hubaghd...@hotmail.com > >wrote: > > > > > > > > Hi, > > > Foe the sender, I wrote a encoder for MessagePack. Why the consumer > > > doesn't need the accompanying decoder? > > > Thanks. >
