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 <[email protected]> Authored: Wed May 28 16:58:05 2014 -0700 Committer: Neha Narkhede <[email protected]> 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 }
