时间戳

首页 > 解决方案 > kafka-consumer-groups.sh 何时将 CURRENT_OFFSET 显示为“-”？

apache-kafka - kafka-consumer-groups.sh 何时将 CURRENT_OFFSET 显示为“-”？

问题描述

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 "-"

什么可以产生这种情况，这对消费者意味着什么？

我正在这个主题（16 个分区）上运行一个 KafkaStreams 应用程序，有 3 个实例，每个实例一个线程。我最近有两个节点发生故障，并且这个主题的复制 = 2，所以一些分区在一段时间内没有领导者。

处于这种状态的分区如何影响普通消费者或 Kafka Streams 应用程序？

标签： apache-kafkapartitioningkafka-consumer-apiapache-kafka-streams

解决方案

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

推荐阅读