Apache Kafka 生产者配置：'request.timeout.ms' 对比。 '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和[=26之间的区别=] 生产者配置。是否包括所有重试的最长时间？还是每次重试都有自己的超时时间？

Answer 1

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

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

详情看这个。 https://cwiki.apache.org/confluence/display/KAFKA/KIP-19+-+Add+a+request+timeout+to+NetworkClient

Apache Kafka 生产者配置：'request.timeout.ms' 对比。 'max.block.ms' 个属性

Apache Kafka Producer Config: 'request.timeout.ms' VS. 'max.block.ms' properties

apache-kafka

kafka-producer-api