KIP-8 — Add a flush method to the producer API

Accepted Producer

Adds a KafkaProducer.flush() method that blocks until all buffered records in the RecordAccumulator have been sent and acknowledged. Without flush(), callers had to iterate over all returned Future objects to wait for send completion, and with linger.ms > 0 the last batch was artificially delayed waiting for more records that would never arrive.

Details