Jay Kreps created KAFKA-1865:
--------------------------------
Summary: Investigate adding a flush() call to new producer API
Key: KAFKA-1865
URL: https://issues.apache.org/jira/browse/KAFKA-1865
Project: Kafka
Issue Type: Bug
Reporter: Jay Kreps
The postconditions of this would be that any record enqueued prior to flush()
would have completed being sent (either successfully or not).
An open question is whether you can continue sending new records while this
call is executing (on other threads).
We should only do this if it doesn't add inefficiencies for people who don't
use it.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
