如何查看kafka的topic的消费者组有没有积压

Kafka 自带的命令行工具 kafka-consumer-groups.sh 来查看消费者组的消费情况，包括是否有积压。

具体步骤如下：

打开命令行终端，进入 Kafka 安装目录下的 bin 文件夹。

输入以下命令，查看消费者组的消费情况：

./kafka-consumer-groups.sh –bootstrap-server –describe –group
kafka-consumer-groups.sh –bootstrap-server 11.243.32.212:9092 –describe –group logstash1
其中， 是 Kafka 集群的 broker 地址，多个 broker 之间用逗号分隔； 是要查看的消费者组的名称。

查看输出结果，其中 CURRENT-OFFSET 表示当前消费的偏移量，LOG-END-OFFSET 表示当前主题分区的最新偏移量，LAG 表示当前消费者组滞后的消息数量。如果 LAG 不为 0，说明消费者组存在积压。

例如，下面是一个消费者组存在积压的示例输出：

GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
my-consumer my-topic 0 1242 1250 8 consumer-1-125a4668-0f07-4b22-b822-1cb16f8e4b4f /127.0.0.1 consumer-1
my-consumer my-topic 1 1035 1035 0 consumer-1-125a4668-0f07-4b22-b822-1cb16f8e4b4f /127.0.0.1 consumer-1
my-consumer my-topic 2 1060 1062 2 consumer-1-125a4668-0f07-4b22-b822-1cb16f8e4b4f /127.0.0.1 consumer-1
在这个示例中，消费者组 my-consumer 在主题 my-topic 的分区 0 和 2 中存在积压。