【问题标题】:What is the difference between --to-latest and --to-current offset values--to-latest 和 --to-current 偏移值有什么区别
【发布时间】: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


    【解决方案1】:

    latest 选项忽略已提交的偏移量,并在所有分区的最高偏移量处寻找组。

    当前选项重置为已提交的偏移量,我相信这对于任何非活动消费者组来说都是无操作的。

    对于零延迟组,两个选项会做同样的事情。

    来源:https://github.com/apache/kafka/blob/3.0/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala

    KIP-122 中解释了当前选项

    当我们只想按分区打印和/或备份当前偏移量时。

    【讨论】:

      猜你喜欢
      • 2011-01-27
      • 1970-01-01
      • 2011-05-09
      • 1970-01-01
      • 1970-01-01
      • 2016-12-31
      • 2010-10-18
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多