解释仓/ kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper本地主机：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的解释。

我只有一个消费者正在运行，使用下面的命令，那么为什么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确实有两个分区。