...

@Override
public booleanvoid flush(Duration timeout)

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

Proposed Changes

Before this proposal, there is only one flush() API, which the caller will be blocked util all the pending batches(at the moment of calling flush()) succeed or exhaust all the retries.

...