[KAFKA-7711] Add a bounded flush() API to Kafka Producer

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: producer
• Labels: needs-kip
• Assignee: Unassigned
• Reporter: kun du
• Created: 06/Dec/18 19:54
• Updated: 25/Feb/20 05:30

Description

Currently the call to Producer.flush() can be hang there for indeterminate time.

It is a good idea to add a bounded flush() API and timeout if producer is unable to flush all the batch records in a limited time. In this way the caller of flush() has a chance to decide what to do next instead of just wait forever.

Issue Links

• mentioned in: Page Loading...