KAFKA-1358: Fixing minor log4j statement

11 years ago · 0ffec142a9
1 changed files with 1 additions and 0 deletions
--- a/core/src/main/scala/kafka/controller/KafkaController.scala
+++ b/core/src/main/scala/kafka/controller/KafkaController.scala
@ -1063,6 +1063,7 @@ class KafkaController(val config : KafkaConfig, zkClient: ZkClient) extends Logg
				@@ -1063,6 +1063,7 @@ class KafkaController(val config : KafkaConfig, zkClient: ZkClient) extends Logg
     */
    @throws(classOf[Exception])
    def handleNewSession() {
+      info("ZK expired; shut down all controller components and try to re-elect")
      inLock(controllerContext.controllerLock) {
        onControllerResignation()
        controllerElector.elect