apache-kafka - Apache Kafka 生产者配置 : 'request.timeout.ms' VS. 'max.block.ms' 属性

Question

鉴于以下同步 kafka 生产者

Properties props = new Properties();
props.put("max.block.ms", 30000);
props.put("request.timeout.ms", 30000);
props.put("retries", 5);

KafkaProducer<String, byte[]> produce = new KafkaProducer<>(props);

//Send message
producer.send(producerRecord).get();

帮我理解 之间的区别request.timeout.ms 和 max.block.ms 生产者配置。是否包括所有重试的最大时间？还是每次重试都有自己的超时？

Answer 1

request.timeout.ms 用于超时请求，我会将其设置为我可以等待响应的最长时间。

max.block.ms 用于生产者阻塞缓冲时间、序列化时间等。

有关详细信息，请查看这一点。
https://cwiki.apache.org/confluence/display/KAFKA/KIP-19+-+Add+a+request+timeout+to+NetworkClient