@hzxa21 It seems that if controller receives ControllerMovedException, the controller should not simply remove all events from the controller queue. Events such as `Reelect` and `ControlledShutdown` probably should stay in the queue as these events need to be processed even if the broker is not controller. If we do this, we can solve the race condition without having the additional `isShuttingDown`. And we can also make the change that Jun suggested previously without worrying about `Reelect` event being removed from the controller event queue. What do you think?
[ Full content available at: https://github.com/apache/kafka/pull/5101 ] This message was relayed via gitbox.apache.org for [email protected]
