解释 bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group group1

Question

有人可以解释以下命令的输出：

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

输出：

Group           Topic                          Pid Offset          logSize         Lag             Owner
group1          nil_RF2_P2                     0   2               2               0               group1_nilotpal-1469374217666-b7619d68-0
group1          nil_RF2_P2                     1   2               3               1               group1_nilotpal-1469374217666-b7619d68-0

我需要对每列 Pid、Offset、logsize、Lag、Owner 进行解释。

我目前只有 1 个消费者 运行，使用以下命令，那么为什么上面的命令出现 2 行。

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic nil_RF2_P2  --consumer.config config/consumer1.properties 
sarkar
hello all again!!

提前致谢！！

Answer 1

这些列确实具有以下含义：

• Pid:分区ID
• Offset: 相应消费者组的分区的最新提交偏移量
• logSize:分区存储的消息数
• Lag：分区对应消费组（即lag = logSize - offset）尚未消费的消息数
• Owner：运行 消费者线程的唯一 ID

此外，ConsumerOffestChecker 为每个主题分区显示一行。您的主题 nil_RF2_P2 确实有两个分区。