Hi team,

I want to understanding the meaning of request.timeout.ms that is used in
producer. As per the doc this property is used to expire records that have
been waiting for response from server for more than request.timeout.ms
which also means the records have been sitting in InFlightRequests for more
than request.timeout.ms.

But look at the codebase I discovered that request.timeout.ms is used for
another purpose: to expire records that sit in accumulator for more than
request.timeout.ms. I believe records that are in accumulator should not be
in InFlightRequests therefore request.timeout.ms is used to expire two
types of records: Records that sit in InFlightRequests for more than
request.timeout.ms and records that sit in accumulator for  more than
request.timeout.ms. Is this understanding correct?

Reply via email to