【发布时间】:2022-01-16 21:42:30
【问题描述】:
以下是 Apache Kafka 存储库中的注释。
--to-latest : Reset offsets to latest offset.
--to-current : Resets offsets to current offset.
两个选项有什么区别?他们不是一样的吗?
【问题讨论】:
标签: apache-kafka kafka-consumer-api
以下是 Apache Kafka 存储库中的注释。
--to-latest : Reset offsets to latest offset.
--to-current : Resets offsets to current offset.
两个选项有什么区别?他们不是一样的吗?
【问题讨论】:
标签: apache-kafka kafka-consumer-api
latest 选项忽略已提交的偏移量,并在所有分区的最高偏移量处寻找组。
当前选项重置为已提交的偏移量,我相信这对于任何非活动消费者组来说都是无操作的。
对于零延迟组,两个选项会做同样的事情。
来源:https://github.com/apache/kafka/blob/3.0/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
KIP-122 中解释了当前选项
当我们只想按分区打印和/或备份当前偏移量时。
【讨论】: