如何检查分配给主题特定分区的Kafka消费者的滞后？答案

【问题标题】：How to check the lag of a consumer in Kafka which is assigned with a particular partition of a topic?如何检查分配给主题特定分区的Kafka消费者的滞后？
【发布时间】：2018-06-26 09:49:52
【问题描述】：

我想检查手动分配给特定主题的消费者组的滞后，这可能吗？ .我正在使用 Kafka - 0.10.0.1。我使用了 sh kafka-run-class.sh kafka.admin.ConsumerGroupCommand —new-consumer —describe —bootstrap-server localhost:9092 —group test 但它说不存在任何组，所以我想知道当我们手动分配分区时，我们可以检查消费者的延迟。

【问题讨论】：

更高版本即使对于独立消费者也能显示滞后。

标签： apache-kafka kafka-consumer-api

【解决方案1】：

在 Nussknacker 中，我们使用AKHQ GUI 工具，该工具提供各种监控选项，如消费者和消费者组滞后，以及作为主题、主题数据和模式注册表管理的一般 Kafka 操作

【讨论】：

【解决方案2】：

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

。

如果您想要 API 支持或视觉延迟监控，您可以使用 https://github.com/yahoo/kafka-manager

【讨论】：

即使没有帮助
那么你是把你的偏移数据保存在zookeeper上还是kafka broker上？您的消费者在运行吗？
kafka 中的偏移量，是的，消费者正在运行，我正在使用 consumer.assign() 从主题的特定分区中消费
能不能直接查询__consumer-offset查询group和consumers。你可以使用这个链接ctheu.com/2017/08/07/looking-at-kafka-s-consumers-offsets