代码之家 › 专栏 › 技术社区 › xmar

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

apache-kafka-streams kafka-consumer-api partitioning apache-kafka

xmar · 技术社区 · 7 年前

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

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个实例,每个实例一个线程。我最近遇到两个节点的故障,这个主题的replication=2,所以有些分区在一段时间内没有leader。

分区处于这种状态如何影响常规使用者或Kafka流应用程序?

1 回复 | 直到 7 年前

Matthias J. Sax 7 年前

如果消费者还没有提交其补偿,您将看到一个破折号 - 意思是不可用。出于同样的原因,无法计算滞后并显示 - .

推荐文章

Stella · Kafka流处理期间处理数据时出现异常

7 年前

Stella · kafka流中的处理器节点

7 年前

mukesh210 · 卡夫卡流:Lib Rocks数据库上的UnsatifiedLinkError

7 年前

el323 · Kafka流:通过Json日志中的键进行分组

7 年前

Suchita · 如何使用Avro反序列化器和Avro序列化器为KafkaStreams编写Junit测试用例

7 年前

Cemo · 如何获得有关GlobalKTable状态存储更新的通知?

7 年前

px5x2 · Kafka将GlobalKTable同步流传输到应用程序

7 年前

Dth · 加工机为Kafka流中的单个任务多次调用init()

7 年前

nattyddubbs · Kafka Streams多实例设计含义

7 年前

dvlcis · 如何使用卡夫卡流窗口为烛台图生成创建一条记录

7 年前