You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2015/12/10 22:09:48 UTC
kafka git commit: KAFKA-2926;
[MirrorMaker] InternalRebalancer calls wrong method of external
rebalancer
Repository: kafka
Updated Branches:
refs/heads/trunk 9d23b512c -> 882fe0128
KAFKA-2926; [MirrorMaker] InternalRebalancer calls wrong method of external rebalancer
…ternal rebalancer
Author: Gwen Shapira <cs...@gmail.com>
Reviewers: Ismael Juma <is...@juma.me.uk>, Sriharsha Chintalapani <ha...@hortonworks.com>, Ewen Cheslack-Postava <ew...@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 <cs...@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]) {