kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2301: Warn ConsumerOffsetChecker as deprecated; reviewed by Ewen Cheslack-Postava and Guozhang Wang
Date Tue, 28 Jul 2015 21:08:42 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 4389a11f6 -> 57386de64


KAFKA-2301: Warn ConsumerOffsetChecker as deprecated; reviewed by Ewen Cheslack-Postava and
Guozhang Wang


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

Branch: refs/heads/trunk
Commit: 57386de64530edcb54e9dae4566fb6d4a8b4700e
Parents: 4389a11
Author: Ashish Singh <asingh@cloudera.com>
Authored: Tue Jul 28 14:09:10 2015 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Jul 28 14:09:10 2015 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/57386de6/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 3d52f62..c39fbfe 100644
--- a/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala
+++ b/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala
@@ -107,6 +107,8 @@ object ConsumerOffsetChecker extends Logging {
   }
 
   def main(args: Array[String]) {
+    warn("WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following
0.9.0. Use ConsumerGroupCommand instead.")
+
     val parser = new OptionParser()
 
     val zkConnectOpt = parser.accepts("zookeeper", "ZooKeeper connect string.").


Mime
View raw message