小编Car*_*des的帖子

我正在使用新的kafka生成器客户端并将timeout.ms属性设置为50毫秒.

以下是生产者使用的完整配置:

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");

在高负载的某些时刻请求平均响应时间是4秒,但我没有得到任何超时错误.

有人知道这个超时是如何计算的,它何时开始计算以及何时结束？有没有办法配置从生成器的send方法被调用的那一刻开始的超时？