You are right. But in line 133 we will check the epoch value. If it is different from what we expected, we will throw `ControllerMovedException`. In the case of `/controller` gets deleted between line 123 and 127, and another broker becomes the controller, the controller epoch will increment accordingly, causing line 133 to fail.
[ Full content available at: https://github.com/apache/kafka/pull/5101 ] This message was relayed via gitbox.apache.org for [email protected]
