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:09:48 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 9d23b512c -> 882fe0128


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


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

Branch: refs/heads/trunk
Commit: 882fe01284ef7d61e19e4a527fb7c18471a8c074
Parents: 9d23b51
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:33 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/882fe012/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 35bdfc4..d271c7c 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