You can register a callback for each message sent. The callback will be
called when the message is sent successfully or failed.

Thanks,

Jun

On Tue, Feb 17, 2015 at 4:11 PM, JAmes Atwill <jatw...@linuxstuff.org>
wrote:

> Hi!
>
> I'm using the new KafkaProducer in 0.8.2.0.
>
> I have thousands of "Nodes" which receive messages. Each message
> idempotently mutates the state of the Node, so while duplicate messages are
> fine, missed messages are not.
>
> I'm writing these messages into a topic with dozens of partitions.
>
> Am I correct in believing that I'll have to manually manage having one
> message "in flight" per "node" at a time? Or is there a mechanism to say
> "This message and all messages after it for this partition were rejected"?
> (or something similar)
>
> Thanks!
>
>   JAmes
>

Reply via email to