ethrbunny ethrbunny - 9 days ago 6
Java Question

kafka (inactive) consumer lag monitoring

I using Confluent Kafka 0.10.0. I want to monitor consumer offset(s) for purposes of alerting.

Where are the values for a Consumer Group stored when the group isn't active? Is there a programmatic method to extract these? (IE something in the kafka api)

Similarly - is there a way to get a list of groups that includes the inactive ones?




Note:



The only way to (presently) list / describe the groups for my project is to use

kafka-consumer-groups ... --new-consumer
.

Answer

Have a look at the kafka documentation. The following page claims to be a working example of just what you want: https://cwiki.apache.org/confluence/display/KAFKA/Committing+and+fetching+consumer+offsets+in+Kafka

Comments