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 中存在积压。

Logo

大数据从业者之家,一起探索大数据的无限可能!

更多推荐