Repository: kafka Updated Branches: refs/heads/trunk 9d23b512c -> 882fe0128
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 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 <[email protected]> Authored: Thu Dec 10 13:09:33 2015 -0800 Committer: Ewen Cheslack-Postava <[email protected]> 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]) {
