kafka.server.KafkaHealthcheck
When we get a SessionExpired event, we lost all ephemeral nodes and zkclient has reestablished a connection for us. We need to re-register this broker in the broker registry.
Called after the zookeeper session has expired and a new session has been created.
Called after the zookeeper session has expired and a new session has been created. You would have to re-create any ephemeral nodes here.
On any error.
When we get a SessionExpired event, we lost all ephemeral nodes and zkclient has reestablished a connection for us. We need to re-register this broker in the broker registry.