Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> When the consumer needs the decoder?


Copy link to this message
-
Re: When the consumer needs the decoder?
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.
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB