Конфигурация производителя Apache Kafka: VS. VS. request.timeout.ms. свойства «max.block.ms»

Question

Учитывая под синхронной производителю Кафка

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