kafka-consumer-groups.sh 什么时候显示 CURRENT_OFFSET 为“-”？

Question

CURRENT-OFFSET 列显示“-”是什么意思？

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 应用程序？

Answer 1

如果消费者尚未提交其偏移量，您将看到一个破折号 -，表示不可用。出于同样的原因，无法计算滞后并显示 -.

kafka-consumer-groups.sh 什么时候显示 CURRENT_OFFSET 为“-”？

When does kafka-consumer-groups.sh show CURRENT_OFFSET as "-"?

partitioning

apache-kafka

kafka-consumer-api

apache-kafka-streams