kafka.controller.KafkaController
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.