kafka查看消息堆积时可以使用kafka-consumer-groups.sh脚本命令,此命令以主题-分区的维度展示消费者分配情况及消息offset情况。
命令如下:
kafka-consumer-groups.sh --bootstrap-server 192.168.94.151:9092 --describe --group YourGroupName
若消费者组消费的topic比较多,可以加grep topic等条件过滤
从左到右分别为
消费者组 - topic - 分区 - 当前消费者消费进度 - 当前生产消息总数 - 消息堆积数(前两者差值),后面 - 为consumer信息,因consumer未启动,所以显示为-
总结:
消息堆积数LAG = LOG-END-OFFSET - CURRENT-OFFSET
后面发文会详细讲解此命令使用,暂请关注