CURRENT-OFFSET中的破折号代表什么

Sah*_*pta 2 apache-kafka kafka-consumer-api

参考以下消费者组描述的屏幕截图,我试图了解“-”在这里对于 CURRENT-OFFSET 意味着什么。它是否表示即使分区已分配给消费者,也不会从分区 1 和 3 消费消息。分区 1 和 3 的 LOG-END 偏移量分别为 281 和 277。

在此处输入图片说明

ame*_*tic 6

CURRENT-OFFSET表示该消费者实例的分区消耗消息的当前最大偏移量,而LOG-END-OFFSET是分区中最新消息的偏移量。

在您的情况下,消费者已经消费了分区 0 和 2 的所有消息,这就是这两个分区的滞后为零的原因。但是,对于分区 1 和 3,要么没有为它们分配消费者实例,要么消费者无法读取这两个分区的任何记录。