Reputation: 25790
I use Kafka 2.0.0 (Commit:3402a8361b734732)
and would like to check the Kafka consumer lag on the topic for the particular group
kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic imdb.title --zookeeper localhost:2181 --group decisionwanted
but it returns the following error:
Error: Could not find or load main class kafka.tools.ConsumerOffsetChecker
How to properly get the lag value on this Kafka version?
Upvotes: 0
Views: 977
Reputation: 675
This class has apparently been removed in 1.0. Use kafka-consumer-groups.sh
to get consumer group details.
Upvotes: 1