kafka消息堆积的研究
1,查看某个broker所拥有的consumer group
bin/kafka-consumer-groups.sh --list --bootstrap-server 10.80.62.159:9092
2,查看local-task messages堆积情况:
bin/kafka-consumer-groups.sh --describe --bootstrap-server 10.80.62.159:9092 -group local-task
如下图:LAG = LOG-END-OFFSET - CURRENT-OFFSET,表示message堆积,即消费延迟数量。