[KAFKA-1865] Add a flush() call to the new producer API

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.9.0.0
• Assignee: Jay Kreps
• Reporter: Jay Kreps
• Created: 15/Jan/15 02:17
• Updated: 12/Mar/15 04:06
• Resolved: 28/Feb/15 23:52

Description

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.

Issue Links

• blocks: SAMZA-524 Update KafkaSystemProducer after Kafka provides a flush behavior
• is related to: SAMZA-227 Upgrade KafkaSystemProducer to new API
• relates to: KAFKA-1863 Exception categories / hierarchy in clients