Producer.flush

Wait until all outstanding produce requests, et.al, are completed. This should typically be done prior to destroying a producer instance to make sure all queued and in-flight produce requests are completed before terminating.

Note: This function will call poll() and thus trigger callbacks.

timed_out if \p timeout_ms was reached before all outstanding requests were completed, else ErrorCode.no_error

class Producer
flush
(
int timeout_ms = 60_000
)

Meta