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 <[email protected]> Reviewers: Ismael Juma <[email protected]>, Sriharsha Chintalapani <[email protected]>, Ewen Cheslack-Postava <[email protected]> Closes #611 from gwenshap/KAFKA-2926 (cherry picked from commit 882fe01284ef7d61e19e4a527fb7c18471a8c074) Signed-off-by: Ewen Cheslack-Postava <[email protected]> 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 <[email protected]> Authored: Thu Dec 10 13:09:33 2015 -0800 Committer: Ewen Cheslack-Postava <[email protected]> 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]) {
