From 0d6a581d14bd17a734f2a33da29978d7cd4ac1fa Mon Sep 17 00:00:00 2001 From: Jun Rao Date: Thu, 15 Jan 2015 17:02:23 -0800 Subject: [PATCH] remove the overrides --- core/src/main/scala/kafka/tools/ConsoleConsumer.scala | 4 ---- 1 file changed, 4 deletions(-) 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")) { -- 1.8.5.2 (Apple Git-48)