...

Current state: Under Discussion

Discussion thread: N/A Here

JIRA: KAFKA-7711 

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

Motivation

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

It would be great 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.

Public Interfaces

A new API will be added to Kafka producer

...