Thanks, I created KAFKA-909 for the feature request. As an aside, I see that in Jira, the available kafka versions are 0.8, 0.8.1 and 0.9. I see the branch in github for 0.8, does this mean that the trunk is 0.8.1? And 9 is future planning on jira, but not established in github, yet?
Thanks, Rob Withers Staff Analyst/Developer o: (720) 514-8963 c: (571) 262-1873 -----Original Message----- From: Withers, Robert [mailto:robert.with...@dish.com] Sent: Friday, May 17, 2013 11:49 AM To: users@kafka.apache.org Subject: RE: could an Encoder/Decoder be stateful? I shall. Thanks! Thanks, Rob Withers Staff Analyst/Developer o: (720) 514-8963 c: (571) 262-1873 -----Original Message----- From: Jun Rao [mailto:jun...@gmail.com] Sent: Friday, May 17, 2013 8:53 AM To: users@kafka.apache.org Subject: Re: could an Encoder/Decoder be stateful? Possible, but definitely a post 0.8 item. If you are interested, could you file a jira to track this? Thanks, Jun On Thu, May 16, 2013 at 10:06 PM, Rob Withers <reefed...@gmail.com> wrote: > Could the producer be adapted to support the interface of the consumer? > > Thanks, > rob > > > -----Original Message----- > > From: Jun Rao [mailto:jun...@gmail.com] > > Sent: Thursday, May 16, 2013 10:04 PM > > To: users@kafka.apache.org > > Subject: Re: could an Encoder/Decoder be stateful? > > > > The encoder instance can't be shared in different producers since > > it's instantiated through java reflection. Decoder instance can > > actually be > shared > > by different consumers since it's passed in directly through the > > consumer > api. > > > > Thanks, > > > > Jun > > > > > > On Thu, May 16, 2013 at 5:58 AM, Withers, Robert > > <robert.with...@dish.com>wrote: > > > > > Is there a way to share an encoder instance, or inject shared > > > state, across producers/consumers? Guice? > > > ________________________________________ > > > From: Jun Rao [jun...@gmail.com] > > > Sent: Wednesday, May 15, 2013 11:02 PM > > > To: users@kafka.apache.org > > > Subject: Re: could an Encoder/Decoder be stateful? > > > > > > Each producer/consumer uses a single instance of the encoder/decoder. > > > > > > Thanks, > > > > > > Jun > > > > > > > > > On Wed, May 15, 2013 at 7:20 PM, Rob Withers <reefed...@gmail.com> > > wrote: > > > > > > > Or is the same instance used for each (un)marshaling? It would > > > > be nice > > > to > > > > have a cache and a duplicateMsgChecker function, from the app > > > > above to ensure transactional guarantees, and object ref > > > > substitutions during (de)serialization, to enable durable > > > > distributed objects and > > promises. > > > > > > > > > > > > > > > > Thanks, > > > > > > > > rob > > > > > > > > > > > > >
