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,说明消费者组存在积压。
例如,下面是一个消费者组存在积压的示例输出:文章来源:https://www.toymoban.com/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
在这个示例中,消费者组 my-consumer 在主题 my-topic 的分区 0 和 2 中存在积压。文章来源地址https://www.toymoban.com/news/detail-417342.html
到了这里,关于如何查看kafka的topic的消费者组有没有积压的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!