kafka查看未被消费的日志数量

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker  –zookeeper localhost:2181  –group logstash

123

Offset表示已经消费的message条数
logSize表示全部的message条数
Lag表示未消费的message条数
每个分区只能有一个消费者,也就是消费者和分区之前是一对多的关系。如上图所示一共三台logstash,每台logstash上启5和线程,所以一共15个消费者,而该Topic共16个分区,可以看到logstash 109的线程0对应了0和1两个分区