Hi Matthias, the bin/kafka-consumer-groups.sh utility is exactly what the user in http://grokbase.com/t/kafka/users/163rrq9ne8/new-consumer-group-not-showing-up has used. It seems that the broker is not returning consumer groups that don't participate in the consumer group balancing mechanism.
On Fri, Nov 4, 2016 at 6:07 PM, Matthias J. Sax <matth...@confluent.io> wrote: > -----BEGIN PGP SIGNED MESSAGE----- > Hash: SHA512 > > Robert, > > you can use bin/kafka-consumer-groups.sh instead. > > > bin/kafka-consumer-offset-checker.sh [2016-11-04 10:05:07,852] WARN > > WARNING: ConsumerOffsetChecker is deprecated and will be dropped in > > releases following 0.9.0. Use ConsumerGroupCommand instead. > > (kafka.tools.ConsumerOffsetChecker$) > > > - -Matthias > > On 11/3/16 4:07 AM, Robert Metzger wrote: > > Hi, > > > > some Flink users recently noticed that they can not check the > > consumer lag when using Flink's kafka consumer [1]. According to > > this discussion on the Kafka user list [2] the > > kafka-consumer-groups.sh utility doesn't work with KafkaConsumers > > with manual partition assignment. > > > > Is there a way to get the consumer lag for a consumer that > > regularly commits its offsets to the broker? > > > > Regards, Robert > > > > > > [1] https://issues.apache.org/jira/browse/FLINK-5001 [2] > > http://grokbase.com/t/kafka/users/163rrq9ne8/new-consumer- > group-not-showing-up > > > -----BEGIN PGP SIGNATURE----- > Comment: GPGTools - https://gpgtools.org > > iQIcBAEBCgAGBQJYHMBkAAoJECnhiMLycopPJvEQALdx2dOVa30QsDBtNIJAzwwJ > tk+ZS3lgefNkAWYBMccNTDFqDH0OtLKUhi9Pproye0LTItlaNGYgemC7kzzPnlDv > R6PrJe+GzRNd13eNSBzb7kJ9nxodsZ9flpUsMrX3k2g3v6w6cwV7Xon1LlHV5HtO > xbJ0ei41lNcBFjbgYFbwyzsS+W3FQt1FTw/we4mL3TwaBYwHG5pfByK0eC0NUEEy > Q2rSPnZ8701igC4RJoWRIe0QibzZSdzEk/S8rWpNxTrmG/TaBhM2mObbf96iqM0J > VvJcUiuUpAY/CKiOY6tjCGRpCAGYdrdPismaTQA6hGxzr+91l3eXebn1lFEw2Auc > E0fbkZ5XoNo/JQaHcDA2M+iwVZZMIOP/yfierkG7g3XmYfbCpIKd9+AU79GYGwe+ > nhCUB2BbhEi+saNharAHtm6ai1T55bmSnCBYiz14wJpEYYzDJv1BnRN9YvV3Topl > GNMSK3/zWIALXPp8fFE0JFxX0syaGRqMS5XqlsnklulCaeB/M1gWwGyKxYF+cAWG > 5F5kuKGvr8YgNmRPSOAO8sastbL9se1Kw6uDQj0eN8kimbXptCw+LtEOlQ3z9cgb > IQcbl33oJUcUJdUejQ34rGK84P59CVzIt2R7r722QwJYE9pWBIR9S/+Ft4QnkBaE > VnmHxH/PmQrXMTl8DYs1 > =wVbw > -----END PGP SIGNATURE----- >
