That is correct. KIP-19 has the details: https://cwiki.apache.org/confluence/display/KAFKA/KIP-19+-+Add+a+request+timeout+to+NetworkClient .
-Jason On Fri, Jan 29, 2016 at 3:08 AM, tao xiao <xiaotao...@gmail.com> wrote: > 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? >
