Kafka 自帶的命令行工具 kafka-consumer-groups.sh 來(lái)查看消費(fèi)者組的消費(fèi)情況，包括是否有積壓。
具體步驟如下：
打開(kāi)命令行終端，進(jìn)入 Kafka 安裝目錄下的 bin 文件夾。
輸入以下命令，查看消費(fèi)者組的消費(fèi)情況：
./kafka-consumer-groups.sh --bootstrap-server --describe --group
kafka-consumer-groups.sh --bootstrap-server 11.243.32.212:9092 --describe --group logstash1
其中， 是 Kafka 集群的 broker 地址，多個(gè) broker 之間用逗號(hào)分隔； 是要查看的消費(fèi)者組的名稱。
查看輸出結(jié)果，其中 CURRENT-OFFSET 表示當(dāng)前消費(fèi)的偏移量，LOG-END-OFFSET 表示當(dāng)前主題分區(qū)的最新偏移量，LAG 表示當(dāng)前消費(fèi)者組滯后的消息數(shù)量。如果 LAG 不為 0，說(shuō)明消費(fèi)者組存在積壓。
例如，下面是一個(gè)消費(fèi)者組存在積壓的示例輸出：文章來(lái)源：http://www.zghlxwxcb.cn/news/detail-417342.html
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
在這個(gè)示例中，消費(fèi)者組 my-consumer 在主題 my-topic 的分區(qū) 0 和 2 中存在積壓。文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-417342.html
到了這里，關(guān)于如何查看kafka的topic的消費(fèi)者組有沒(méi)有積壓的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
