How to check the lag of a consumer in Kafka which is assigned with a particular partition of a topic?

Question

I want to check the lag for a consumer group which was assigned manually to particular topic , is this possible ? . I am using Kafka - 0.10.0.1 .I used sh kafka-run-class.sh kafka.admin.ConsumerGroupCommand —new-consumer —describe —bootstrap-server localhost:9092 —group test but it says no group exists , so i wonder when we assign a partition manually can we check the lag for the consumer.

Later version is able to show the lags even for standalone consumers. — amethystic

Abhimanyu Abhimanyu · Accepted Answer · 2018-01-17T14:51:22

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group

.

If You want API support or visual lag monitoring you can use https://github.com/yahoo/kafka-manager

How to check the lag of a consumer in Kafka which is assigned with a particular partition of a topic?

1 Answers