Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - CallbackHandler in Kafka 0.8


Copy link to this message
-
Re: CallbackHandler in Kafka 0.8
Joel Koshy 2013-07-02, 21:37
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 <[EMAIL PROTECTED]> wrote:
> Hello-
>
>    Is CallbackHandler supported in Kafka 0.8 for async producers?
>
> If yes, can I use it to alter the batched messages before they are pushed
> to broker? For example, I may want to delete some of the messages in the
> batch based on some business logic in my application?
>
> If no, is there any alternate way? I want to do some kind of single
> instancing on messages pushed in kafka in last X minutes.
>
> thanks