Looks good to me. I like the idea of not blocking additional sends but not guaranteeing that flush() will deliver them.
I assume that with linger.ms = 0, flush will just be a noop (since the queue will be empty). Is that correct? Gwen On Sun, Feb 8, 2015 at 10:25 AM, Jay Kreps <jay.kr...@gmail.com> wrote: > Following up on our previous thread on making batch send a little easier, > here is a concrete proposal to add a flush() method to the producer: > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-8+-+Add+a+flush+method+to+the+producer+API > > A proposed implementation is here: > https://issues.apache.org/jira/browse/KAFKA-1865 > > Thoughts? > > -Jay >
