2017-09-15 31 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中,這種超時更爲通用,即使對於消費者和管理客戶端也是如此:它是通用請求的超時而不是與寫消息嚴格相關。