重置偏移量

当应用程序启动时,每个分配的分区的初始位置取决于两个属性 startOffsetresetOffsets。如果 resetOffsetsfalse,则应用正常的 Kafka 消费者 auto.offset.reset 语义。即,如果绑定消费者组的某个分区没有提交的偏移量,则位置为 earliestlatest。默认情况下,具有显式 group 的绑定使用 earliest,而匿名绑定(没有 group)使用 latest。这些默认值可以通过设置 startOffset 绑定属性来覆盖。第一次使用特定 group 启动绑定时,将没有提交的偏移量。另一个没有提交偏移量的情况是偏移量已过期。对于现代代理(从 2.1 版本开始)和默认代理属性,偏移量在最后一个成员离开组后 7 天过期。有关更多信息,请参见 offsets.retention.minutes 代理属性。

resetOffsetstrue 时,绑定会应用与代理上没有提交偏移量时类似的语义,就好像此绑定从未从主题中消费过一样;即,任何当前提交的偏移量都会被忽略。

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

  1. 从包含键值对的压缩主题中消费。将 resetOffsets 设置为 true,并将 startOffset 设置为 earliest;绑定将在所有新分配的分区上执行 seekToBeginning

  2. 从包含事件的主题中消费,您只对绑定运行期间发生的事件感兴趣。将 resetOffsets 设置为 true,并将 startOffset 设置为 latest;绑定将在所有新分配的分区上执行 seekToEnd

如果在初始分配后发生重新平衡,则仅对在初始分配期间未分配的任何新分配的分区执行搜索。

要更详细地控制主题偏移量,请参阅 重新平衡监听器;如果提供了监听器,则不应将 resetOffsets 设置为 true,否则会导致错误。