Hi Sachin, You should use the kafka-consumer-groups.sh command. The ConsumerOffsetChecker is deprecated and is only for the old consumer.
Thanks, Damian On Mon, 12 Dec 2016 at 14:32 Sachin Mittal <sjmit...@gmail.com> wrote: > Hi, > I have a streams application running with application id test. > When I try to check consumer lag like you suggested I get the following > issue: > > bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper > localhost:2181 --group test > [2016-12-12 10:26:01,348] WARN WARNING: ConsumerOffsetChecker is > deprecated and will be dropped in releases following 0.9.0. Use > ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$) > SLF4J: Class path contains multiple SLF4J bindings. > SLF4J: Found binding in > > [jar:file:/home/testuser/kafka/kafka_2.10-0.10.0.1/libs/logback-classic-1.0.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] > SLF4J: Found binding in > > [jar:file:/home/testuser/kafka/kafka_2.10-0.10.0.1/libs/slf4j-log4j12-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class] > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an > explanation. > SLF4J: Actual binding is of type > [ch.qos.logback.classic.selector.DefaultContextSelector] > Exiting due to: org.apache.zookeeper.KeeperException$NoNodeException: > KeeperErrorCode = NoNode for /consumers/test/owners. > > Please let me know where I may be going wrong. > I have the kafka logs set in folder > /data01/testuser/kafka-logs > > Under kafka-logs I see many folders with name something like > consumer_offsets_* > > I have the stream dir set in folder > /data01/testuser/kafka-streams/test > > Thanks > Sachin > > > On Sun, Dec 11, 2016 at 2:19 AM, Matthias J. Sax <matth...@confluent.io> > wrote: > > > It's basically just a consumer as any other. The application.id is used > > as consumer group.id. > > > > So just use the available tools you do use to check consumer lag. > > > > > > -Matthias > > > > On 12/9/16 5:49 PM, Jon Yeargers wrote: > > > How would this be done? > > > > > > > >
