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
