Per https://github.com/apache/kafka/pull/5101#discussion_r213122229 `/controller_epoch` should exists and `setControllerEpochRaw` should not return `NONODE`. If that does happen, we will rely on admin to recover and `triggerControllerMove()` will not help. I agree that throwing `ControllerMovedException` is not a good idea. Maybe we should just throw `IllegalStateException` and indicate that is a FATAL error. 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]
