kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joel Koshy <jjkosh...@gmail.com>
Subject Re: CallbackHandler in Kafka 0.8
Date Tue, 02 Jul 2013 21:37:27 GMT
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?



On Tue, Jul 2, 2013 at 10:41 AM, Nitin Supekar <nitin@ecinity.com> 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

View raw message