From 89b8815ffc548de823c6a755418f7c7df20699d7 Mon Sep 17 00:00:00 2001 From: Anatoly Fayngelerin Date: Tue, 9 Dec 2014 09:56:11 -0500 Subject: [PATCH] fixing broken scala 2.9.2 build --- core/src/main/scala/kafka/tools/MirrorMaker.scala | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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 } } -- 1.7.12.4 (Apple Git-37)