---

监控Apache Kafka中的消费者滞后

Kafka消费者组滞后是任何基于Kafka的事件驱动系统的关键性能指标。

在本教程中，我们将构建一个分析应用程序来监控Kafka消费者滞后。

消费者滞后简单地说是消费者最后提交的偏移量与生产者在日志中的结束偏移量之间的差值。换句话说，消费者滞后度量了在任何生产者-消费者系统中生产和消费消息之间的延迟。

在本节中，让我们了解如何确定偏移量值。

2.1. Kafka AdminClient

为了检查消费者组的偏移量值，我们需要管理Kafka客户端。因此，让我们在_LagAnalyzerService_类中编写一个方法来创建_AdminClient_类的实例：