This is called on ControllerMovedException. In this case, we know that another broker has become the controller. We just need to clear the event queue, mark the controller as inactive and call onControllerResignation() . There is no need to do the controller election. If the new controller is gone afterward, every broker's controller path watcher will be triggered and a controller election will be tried. We probably should rename this method accordingly.
Also, we probably want to consolidate this method and triggerControllerMove() somehow. To me, the latter will just do what this method does and one more thing, removing the controller path. [ Full content available at: https://github.com/apache/kafka/pull/5101 ] This message was relayed via gitbox.apache.org for [email protected]
