I re-think about your previous suggestion for checking the payload of `/controller` only and I think it will work. I will check with Onur offline to understand more about `checkedEphemeralCreate` and confirm.
In terms of your second concern, if we already see `getDataResponse.stat.getEphemeralOwner == zooKeeperClient.sessionId`, that means `/controller` has been created successfully. Since the only code path to create `/controller` is within a zookeeper transaction along with the `/controller_epoch` update, we can infer that the controller epoch must get incremented in this case. [ Full content available at: https://github.com/apache/kafka/pull/5101 ] This message was relayed via gitbox.apache.org for [email protected]
