Hi,
Foe the sender, I wrote a encoder for MessagePack. Why the consumer doesn't need the accompanying decoder?
Thanks.    

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 <[EMAIL PROTECTED]>wrote:

>
> Hi,
> Foe the sender, I wrote a encoder for MessagePack. Why the consumer
> doesn't need the accompanying decoder?
> Thanks.

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: [EMAIL PROTECTED]
> To: [EMAIL PROTECTED]
>
> 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 <[EMAIL PROTECTED]>wrote:
>
> >
> > Hi,
> > Foe the sender, I wrote a encoder for MessagePack. Why the consumer
> > doesn't need the accompanying decoder?
> > Thanks.
     

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 <[EMAIL PROTECTED]>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: [EMAIL PROTECTED]
> > To: [EMAIL PROTECTED]
>
> >
> > 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 <[EMAIL PROTECTED]
> >wrote:
> >
> > >
> > > Hi,
> > > Foe the sender, I wrote a encoder for MessagePack. Why the consumer
> > > doesn't need the accompanying decoder?
> > > Thanks.
>