Re: CallbackHandler in Kafka 0.8

2013-07-04 Thread Nitin Supekar
Thanks Joel for the response. Sure, I can achieve same by using some data structure before we push messages to Kafka. I was hoping if I can utilize any kafka capabilities specially as we are using async producer. thanks On Wed, Jul 3, 2013 at 11:18 PM, Joel Koshy wrote: > Hi Nitin, > > > > We

Re: CallbackHandler in Kafka 0.8

2013-07-03 Thread Joel Koshy
Hi Nitin, > We receive events from external source ( for example, facebook status > update events). These events are pushed to kafka queue when received There > is possibility of duplicate event ( multiple facebook status update events > for same account in quick intervals ) coming again and get

Re: CallbackHandler in Kafka 0.8

2013-07-03 Thread Nitin Supekar
Hello- We receive events from external source ( for example, facebook status update events). These events are pushed to kafka queue when received There is possibility of duplicate event ( multiple facebook status update events for same account in quick intervals ) coming again and gets pushed int

Re: CallbackHandler in Kafka 0.8

2013-07-02 Thread Joel Koshy
Callback handlers are no longer supported in 0.8. Can you go into why the filtering needs to be done at this stage as opposed to before actually sending to the producer? Thanks, Joel On Tue, Jul 2, 2013 at 10:41 AM, Nitin Supekar wrote: > Hello- > >Is CallbackHandler supported in Kafka 0.8