Re: Doubts regarding KafkaProducer implemetation

2017-03-13 Thread Manikumar
Hi, java producer waits for the metadata of the given topic to be available. We will get TimeoutException if we didn't get metadata within max.block.ms. As observed by you, this behavior is different from old producer. "retries" config is not applicable to metadata fetch. We can adjust max.block.

Doubts regarding KafkaProducer implemetation

2017-03-13 Thread Madhukar Bharti
Hi, We have three brokers in a cluster with replication factor is 3. We are using Kafka-0.10.0.1. We see some failures on metadata timeout exceptions while producing. We have configured retries=3 and max in flight request=1. After comparing with the old scala Producer code found that in new Produc