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 <[EMAIL PROTECTED]> wrote:
> 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.