kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject kafka git commit: kafka-1813; Build fails for scala 2.9.2; patched by Anatoly Fayngelerin; reviewed by Jun Rao
Date Fri, 12 Dec 2014 19:51:48 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 0ef631bc6 -> 523b36589


kafka-1813; Build fails for scala 2.9.2; patched by Anatoly Fayngelerin; reviewed by Jun Rao


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

Branch: refs/heads/trunk
Commit: 523b36589e942cb99a95debd2c45e795ae533d08
Parents: 0ef631b
Author: Anatoly Fayngelerin <fanatoly@gmail.com>
Authored: Fri Dec 12 11:51:41 2014 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Fri Dec 12 11:51:41 2014 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/MirrorMaker.scala | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/523b3658/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 b06ff60..77d951d 100644
--- a/core/src/main/scala/kafka/tools/MirrorMaker.scala
+++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala
@@ -504,7 +504,10 @@ object MirrorMaker extends Logging with KafkaMetricsGroup {
       if (connector == null) {
         warn("No consumer connector available to commit offset.")
       } else {
-        connector.commitOffsets(isAutoCommit = false, offsetsToCommit)
+        connector.commitOffsets(
+          isAutoCommit = false,
+          topicPartitionOffsets = offsetsToCommit
+        )
         commitCounter += 1
       }
     }


Mime
View raw message