Apache Kafka 2.0 获得消费者滞后

【问题标题】：Apache Kafka 2.0 get the consumer lagApache Kafka 2.0 获得消费者滞后
【发布时间】：2018-11-26 01:12:53
【问题描述】：

我用Kafka 2.0.0 (Commit:3402a8361b734732)

并且想检查特定组主题的 Kafka 消费者滞后

kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic imdb.title --zookeeper localhost:2181 --group decisionwanted

但它返回以下错误：

Error: Could not find or load main class kafka.tools.ConsumerOffsetChecker

如何正确获取此 Kafka 版本的延迟值？

【问题讨论】：

【解决方案1】：

这个类显然在 1.0 中被删除了。使用kafka-consumer-groups.sh 获取消费者组详细信息。

【讨论】：

谢谢！以下命令就像我需要的一样工作kafka-consumer-groups.sh --describe --bootstrap-server localhost:9092 --group decisionwanted