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堆积，即消费延迟数量。