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
