Hi all, I'd like to kick off a discussion for KIP-1059 that suggests adding a new feature to the Producer flush() method.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1059%3A+Enable+the+Producer+flush%28%29+method+to+clear+the+latest+send%28%29+error Cheers, Alieh