New Kafka Timeout

Question

I use the new kafka manufacturer client and set the timeout.ms property to 50 ms.

Here is the complete configuration used in the manufacturer:

props.put("acks", "1");
props.put("buffer.memory", "33554432");
props.put("retries", "1");
props.put("batch.size", "16384");
props.put("client.id", "foo");
props.put("linger.ms", "0");
props.put("timeout.ms", "50");

The average response time of a request during high load times is 4 seconds, but I am not getting any timeout errors.

Does anyone know how this timeout is calculated, when does it start to count and when does it end? Is there a way to set a timeout to start from the moment the producer dispatch method is called?

Answer 1

The new property timeout.msworks with the ackmanufacturer’s configuration . For example, consider the following situation:

ack = all
timeout.ms = 3000

ack = all , , (ISR) , 3000 ms. , .

, .

:

, , , acks. , , . - .

, ack=1 ( 100% , ), ( , ) 50 .