kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA-2926; [MirrorMaker] InternalRebalancer calls wrong method of external rebalancer
Date Thu, 10 Dec 2015 21:10:02 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.9.0 416210ec5 -> ba09aef53


KAFKA-2926; [MirrorMaker] InternalRebalancer calls wrong method of external rebalancer

…ternal rebalancer

Author: Gwen Shapira <cshapi@gmail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>, Sriharsha Chintalapani <harsha@hortonworks.com>,
Ewen Cheslack-Postava <ewen@confluent.io>

Closes #611 from gwenshap/KAFKA-2926

(cherry picked from commit 882fe01284ef7d61e19e4a527fb7c18471a8c074)
Signed-off-by: Ewen Cheslack-Postava <me@ewencp.org>


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

Branch: refs/heads/0.9.0
Commit: ba09aef5355cad265941feefa60748261f55df03
Parents: 416210e
Author: Gwen Shapira <cshapi@gmail.com>
Authored: Thu Dec 10 13:09:33 2015 -0800
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Thu Dec 10 13:09:51 2015 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/MirrorMaker.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ba09aef5/core/src/main/scala/kafka/tools/MirrorMaker.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/MirrorMaker.scala b/core/src/main/scala/kafka/tools/MirrorMaker.scala
index 6e54b85..b093cb2 100755
--- a/core/src/main/scala/kafka/tools/MirrorMaker.scala
+++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala
@@ -555,7 +555,7 @@ object MirrorMaker extends Logging with KafkaMetricsGroup {
     override def onPartitionsRevoked(partitions: util.Collection[TopicPartition]) {
       producer.flush()
       commitOffsets(mirrorMakerConsumer)
-      customRebalanceListenerForNewConsumer.foreach(_.onPartitionsAssigned(partitions))
+      customRebalanceListenerForNewConsumer.foreach(_.onPartitionsRevoked(partitions))
     }
 
     override def onPartitionsAssigned(partitions: util.Collection[TopicPartition]) {


Mime
View raw message