Sah*_*pta 2 apache-kafka kafka-consumer-api
参考以下消费者组描述的屏幕截图,我试图了解“-”在这里对于 CURRENT-OFFSET 意味着什么。它是否表示即使分区已分配给消费者,也不会从分区 1 和 3 消费消息。分区 1 和 3 的 LOG-END 偏移量分别为 281 和 277。
CURRENT-OFFSET表示该消费者实例的分区消耗消息的当前最大偏移量,而LOG-END-OFFSET是分区中最新消息的偏移量。
在您的情况下,消费者已经消费了分区 0 和 2 的所有消息,这就是这两个分区的滞后为零的原因。但是,对于分区 1 和 3,要么没有为它们分配消费者实例,要么消费者无法读取这两个分区的任何记录。
| 归档时间: |
|
| 查看次数: |
3538 次 |
| 最近记录: |