Apache Kafka Producer Config: 'request.timeout.ms' VS. 'Max.block.ms' Eigenschaften

Question

den unter dem Synchron kafka Produzenten Da

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(); 

helfen zu verstehen, mir den Unterschied zwischen request.timeout.ms und max.block.ms Produzenten configs . Enthält die maximale Zeit für alle Wiederholungen? Oder hat jede Wiederholung eine eigene Zeitüberschreitung?

Answer 1

request.timeout.ms wird verwendet, um Timeout-Anfrage, würde ich dies auf die maximale Zeit, die ich auf die Antwort warten kann.

max.block.ms ist für Produzenten zu blockieren Pufferzeit, Serialisierung Zeit usw.

Einzelheiten zu dieser aussehen verwendet. https://cwiki.apache.org/confluence/display/KAFKA/KIP-19+-+Add+a+request+timeout+to+NetworkClient