@Mayuresh On Fri, Mar 20, 2015 at 10:30 PM, Mayuresh Gharat <gharatmayures...@gmail.com> wrote: > But if the entire kafka cluster is down, it would try for some configured > number of retries and would return back an error in future. This is my > understanding. Please correct me if I am wrong.
When I set the "retries" option to 1, and "metadata.fetch.timeout.ms" set to 1000ms, I still noticed that it was blocking indefinitely. The future only errors out /after/ the cluster is back up again.
