Hi, I used the following command bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --group test and I get the following output
Note: This will only show information about consumers that use the Java consumer API (non-ZooKeeper-based consumers). Error: Consumer group 'test' has no active members. What does this mean. It means I can check the offset of consumer only when streams applictaion "test" is running. Thanks Sachin On Mon, Dec 12, 2016 at 8:33 PM, Damian Guy <damian....@gmail.com> wrote: > 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? > > > > > > > > > > > > >
