Hi Sachin That is correct. You can only check the offsets when there is an active member of the consumer group. In this case that would mean that you have at least one instance of your streams application running.
Thanks, Damian On Tue, 13 Dec 2016 at 06:58 Sachin Mittal <sjmit...@gmail.com> wrote: > 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? > > > > > > > > > > > > > > > > > > >
