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.

Reply via email to