kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: KAFKA-1358: Fixing minor log4j statement
Date Thu, 03 Apr 2014 02:13:48 GMT
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 <neha.narkhede@gmail.com>
Authored: Wed Apr 2 19:13:43 2014 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
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


Mime
View raw message