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 >
