重置偏移量

应用启动时，每个分配到的分区的初始位置取决于两个属性：startOffset 和 resetOffsets。如果 resetOffsets 为 false，则应用正常的 Kafka 消费者 auto.offset.reset 语义。也就是说，如果绑定消费者组的分区没有提交的偏移量，则位置为 earliest 或 latest。默认情况下，具有显式 group 的绑定使用 earliest，匿名绑定（没有 group）使用 latest。可以通过设置 startOffset 绑定属性来覆盖这些默认值。绑定首次使用特定 group 启动时，不会有提交的偏移量。另一种没有提交偏移量的情况是偏移量已过期。对于较新的 Broker（自 2.1 版起）和默认 Broker 属性，偏移量在最后一个成员离开组后 7 天过期。有关更多信息，请参阅 Broker 属性 offsets.retention.minutes。

当 resetOffsets 为 true 时，Binder 应用的语义与 Broker 上没有提交偏移量时应用的语义类似，就好像此绑定从未从主题消费过一样；也就是说，任何当前提交的偏移量都会被忽略。

以下是可能使用此功能的两个用例。

要更精细地控制主题偏移量，请参阅 rebalance 监听器；如果提供了监听器，则不应将 resetOffsets 设置为 true，否则会导致错误。