我发现 request.timeout.ms Kafka的0.8.2与Kafka的0.10.0不同。
https://kafka.apache.org/082/documentation.html
https://kafka.apache.org/documentation/
Kafka0.8.2： request.timeout.ms 在将错误发送回客户端之前，代理将等待尝试满足request.required.acks要求的时间量。
Kafka0.11.0： request.timeout.ms 配置控制客户端等待请求响应的最长时间。如果在超时时间过去之前未收到响应，则客户端将在必要时重新发送请求，或者在重试次数用尽时请求失败。
1条答案
按热度按时间8yparm6h1#
在kafka 0.8.2中，request.timeout.ms与生产者相关。如您所知，生产者在三种不同的情况下选择接收ack：刚发送时、leader接收并写入消息时、leader和所有副本接收并写入消息时。超时是代理在发送错误之前等待上述条件之一（用于向生产者发送ack）的时间：ack无法按时发送，超时过期。在kafka0.11中，这个超时更一般，甚至用于使用者和管理客户端：它是一般请求的超时，与写消息没有严格的关系。