KAFKA-2538: Fixing a compilation error in trunk.

Author: Parth Brahmbhatt <[email protected]> Reviewers: Guozhang Wang Closes apache#208 from Parth-Brahmbhatt/KAFKA-2538
alexissellier · Sep 13, 2015 · b7d4043 · b7d4043
1 parent 65bf3af
commit b7d4043
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/kafka/tools/EndToEndLatency.scala b/core/src/main/scala/kafka/tools/EndToEndLatency.scala
@@ -79,7 +79,7 @@ object EndToEndLatency {
     val producer = new KafkaProducer[Array[Byte], Array[Byte]](producerProps)
 
     def finalise() {
-      consumer.commit(CommitType.SYNC)
+      consumer.commitSync()
       producer.close()
       consumer.close()
     }