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-1868; ConsoleConsumer shouldn't override dual.commit.enabled to false if not explicitly set; patched by Jun Rao; reviewed by Jeol Koshy
Date Fri, 16 Jan 2015 01:55:56 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.8.2 a643be62a -> 17c8bdcbb


kafka-1868; ConsoleConsumer shouldn't override dual.commit.enabled to false if not explicitly
set; patched by Jun Rao; reviewed by Jeol Koshy


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

Branch: refs/heads/0.8.2
Commit: 17c8bdcbb42d81db47d03091049588238df7e3c6
Parents: a643be6
Author: Jun Rao <junrao@gmail.com>
Authored: Thu Jan 15 17:55:48 2015 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Thu Jan 15 17:55:48 2015 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/ConsoleConsumer.scala | 4 ----
 1 file changed, 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/17c8bdcb/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/ConsoleConsumer.scala b/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
index 323fc85..e455cb9 100644
--- a/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
+++ b/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
@@ -126,10 +126,6 @@ object ConsoleConsumer extends Logging {
     }
     consumerProps.put("auto.offset.reset", if(options.has(resetBeginningOpt)) "smallest"
else "largest")
     consumerProps.put("zookeeper.connect", options.valueOf(zkConnectOpt))
-    if(!consumerProps.containsKey("dual.commit.enabled"))
-      consumerProps.put("dual.commit.enabled","false")
-    if(!consumerProps.containsKey("offsets.storage"))
-      consumerProps.put("offsets.storage","zookeeper")
 
     if (!options.has(deleteConsumerOffsetsOpt) && options.has(resetBeginningOpt)
&&
        checkZkPathExists(options.valueOf(zkConnectOpt),"/consumers/" + consumerProps.getProperty("group.id")+
"/offsets")) {


Mime
View raw message