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? > > > >
