当前偏移列显示“-”是什么意思?
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应用程序?
1条答案
按热度按时间omtl5h9j1#
如果使用者尚未提交其偏移量,您将看到破折号
-
意思是不可用。出于同样的原因,不能计算和显示滞后-
.