...

Discussion thread: Here

JIRA: KAFKA-7711 

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).PR: KAFKA-7569

Motivation

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

...

This API returns normally if flush succeed in time, i.e all previously sent records have completed ; otherwise if times out before finish sending all records, an InterruptException TimeoutException will be thrown.

Proposed Changes

...