I am using kafka 0.8.2.1 old producer. When one of the kafka node in the remote cluster is down the producer is waiting about 15 minutes before it disconnects and tries to connect to another node. (kafka takes < 1 min to change leaders).
Producer config used: request.required.acks=1 partitioner.class=MyKey message.send.max.retries=3 request.timeout.ms=120000 retry.backoff.ms=2500 I played around with different values of request.timeout.ms, retry.backoff.ms, and topic.metadata.refresh.interval.ms with same results. Is there a way to control the producer's wait so that it returns sooner? Thanks. Mayank.