kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: KAFKA-1459 follow up minor patch
Date Thu, 29 May 2014 16:28:58 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk e73e90e99 -> 26eb1277e


KAFKA-1459 follow up minor patch


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

Branch: refs/heads/trunk
Commit: 26eb1277e502efe1b1c5c4e4382fc80fa231bade
Parents: e73e90e
Author: Sriharsha Chintalapani <schintalapani@hortonworks.com>
Authored: Wed May 28 16:58:05 2014 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Wed May 28 16:58:12 2014 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/26eb1277/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala b/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala
index ae83e4d..19df757 100644
--- a/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala
+++ b/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala
@@ -178,7 +178,7 @@ object ConsumerOffsetChecker extends Logging {
           } catch {
             case z: ZkNoNodeException =>
               if(ZkUtils.pathExists(zkClient,topicDirs.consumerOffsetDir))
-                offsetMap.put(topicAndPartition,0)
+                offsetMap.put(topicAndPartition,-1)
               else
                 throw z
           }


Mime
View raw message