From 24b4e01c251c51e0896887dbf65d92d101750b45 Mon Sep 17 00:00:00 2001
From: Parth Brahmbhatt <brahmbhatt.parth@gmail.com>
Date: Fri, 11 Sep 2015 19:33:08 -0700
Subject: [PATCH] KAFKA-2538: Fixing a compilation error in trunk.

---
 core/src/main/scala/kafka/tools/EndToEndLatency.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/tools/EndToEndLatency.scala b/core/src/main/scala/kafka/tools/EndToEndLatency.scala
index cbaed0aca6ee1..eb2a75c50a8f0 100755
--- 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()
     }