Repository: kafka Updated Branches: refs/heads/0.8.1 2b6375b61 -> 0ffec142a
KAFKA-1358: Fixing minor log4j statement Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/0ffec142 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/0ffec142 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/0ffec142 Branch: refs/heads/0.8.1 Commit: 0ffec142a991849833d9767be07e895428ccaea1 Parents: 2b6375b Author: Neha Narkhede <[email protected]> Authored: Wed Apr 2 19:13:43 2014 -0700 Committer: Neha Narkhede <[email protected]> Committed: Wed Apr 2 19:13:43 2014 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/controller/KafkaController.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/0ffec142/core/src/main/scala/kafka/controller/KafkaController.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/controller/KafkaController.scala b/core/src/main/scala/kafka/controller/KafkaController.scala index 6de8713..d6c0321 100644 --- 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 */ @throws(classOf[Exception]) def handleNewSession() { + info("ZK expired; shut down all controller components and try to re-elect") inLock(controllerContext.controllerLock) { onControllerResignation() controllerElector.elect
