2017-01-24 210 views
4

鉴于以下同步卡夫卡生产Apache Kafka Producer配置:'request.timeout.ms'VS. 'max.block.ms' 性质

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.msmax.block.ms生产CONFIGS之间的区别。是否包括所有重试的最长时间?还是每个重试都有其自己的超时?

回答