Hi all, Currently in our test environment, we found that after one of the broker node crash (reboot or os crash), the client may still be connecting to the crash node to send metadata request or other request, and it needs several minutes to be aware that the connection is timeout then try another node to connect to send the request. Then the client may still not be aware of the metadata change after several minutes.
So I want to add a connect timeout on the client, please take a look at?? https://cwiki.apache.org/confluence/display/KAFKA/KIP-148%3A+Add+a+connect+timeout+for+client Regards, David
