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.").
|