Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.6
-
None
-
None
Description
The producer registers a watcher on /brokers/ids to detect the new set of brokers in the cluster. It uses that to keep the producer pool connections updated. But, this watcher callback should also remove the dead brokers, if any, from its in memory data structure. This is important so that we don't accidentally pick a dead broker to serve a produce request. T