kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject kafka git commit: KAFKA-2437; Trivial follow-up
Date Thu, 03 Sep 2015 01:22:33 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 6f398d63a -> 9223155e9


KAFKA-2437; Trivial follow-up


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9223155e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9223155e
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9223155e

Branch: refs/heads/trunk
Commit: 9223155e9c3f55107197758afc5238fe4cebeaa9
Parents: 6f398d6
Author: Joel Koshy <jjkoshy@gmail.com>
Authored: Wed Sep 2 18:22:26 2015 -0700
Committer: Joel Koshy <jjkoshy@gmail.com>
Committed: Wed Sep 2 18:22:26 2015 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/9223155e/core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala b/core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala
index 9bfec40..2b36b2d 100755
--- a/core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala
+++ b/core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala
@@ -122,9 +122,9 @@ class ZookeeperLeaderElector(controllerContext: ControllerContext,
         val amILeaderBeforeDataChange = amILeader
         leaderId = KafkaController.parseControllerId(data.toString)
         info("New leader is %d".format(leaderId))
-        // The old leader need to resign leadership if it is no longer the leader
+        // The old leader needs to resign leadership if it is no longer the leader
         if (amILeaderBeforeDataChange && !amILeader)
-          onResigningAsLeader
+          onResigningAsLeader()
       }
     }
 


Mime
View raw message