kafka-consumer-groups.sh何时将当前的\u偏移显示为“-”?

2wnc66cl  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(360)

当前偏移列显示“-”是什么意思?

TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID                                        HOST            CLIENT-ID
events          6          -               4021552         -               stream-processor-975c-StreamThread-1-consumer-d6f1 /my.ip  stream-processor-975c-StreamThread-1-consumer
events          2          -               7056462         -               stream-processor-975c-StreamThread-1-consumer-d6f1 /my.ip  stream-processor-975c-StreamThread-1-consumer
events          12         3143580         11052506        7908926         stream-processor-975c-StreamThread-1-consumer-d6f1 /my.ip  stream-processor-975c-StreamThread-1-consumer
... several other entries, some with and some without "-"

什么能产生这种情况,对消费者意味着什么?
我正在这个主题上运行一个kafkastreams应用程序(16个分区),有3个示例,每个线程一个。我最近遇到了两个节点的故障,并且这个主题的复制为2,所以一些分区在一段时间内没有前导。
分区处于这种状态如何影响常规使用者或kafka streams应用程序?

omtl5h9j

omtl5h9j1#

如果使用者尚未提交其偏移量,您将看到破折号 - 意思是不可用。出于同样的原因,不能计算和显示滞后 - .

相关问题