Hi, I am testing Kafka-0.8.2.1 new producer API. For synchronous sending, I am calling future.get() just after producer send.
I killed my broker and started Produce, noticed that it is throwing ExecutionException but after that It is still trying to re-connect to broker and this is keep on going. How we can stop it? I don't want to keep on trying if the broker is not available. In Kafka 0.8.1.1 , after throwing exception It was not trying to re-connect. Is there anything to handle this? I have 1 broker and Zookeeper running on the same. Set metadata.fetch.timeout.ms to 100. Regards, Madhukar
