2017-09-15 169 views
1

嗯,我发现卡夫卡0.8.2的request.timeout.ms的含义与卡夫卡0.10.0不同。卡夫卡制作人'request.timeout.ms'的含义让我很困惑

https://kafka.apache.org/082/documentation.html

https://kafka.apache.org/documentation/

卡夫卡0.8.2: request.timeout.ms 的时间量的经纪人将等待试图满足发回一个错误给客户之前,request.required.acks要求。

Kafka 0.11.0: request.timeout.ms 该配置控制客户端等待请求响应的最长时间。如果在超时过去之前未收到响应,客户端将在必要时重新发送请求,或者如果重试耗尽,请求失败。

回答

1

在Kafka 0.8.2中,request.timeout.ms与生产者有关。正如你知道的,制片人选择接受三种不同的情况:刚刚发送时,领导者收到和写入信息时,领导者和所有副本接收和写入信息。超时是代理在发送错误之前等待上述条件之一(用于向生产者发送确认)的时间:确认无法按时发送并且超时过期。在Kafka 0.11中,这种超时更为通用,即使对于消费者和管理客户端也是如此:它是通用请求的超时而不是与写消息严格相关。