auto.offset.reset参数一般有3种赋值情况

  • none
  • earliest
  • latest

官方介绍作用

kafka中没有offset时,不论是什么原因,offset没了,这是auto.offset.reset配置就会起作用。

赋值说明介绍

1. none

如果没有为消费者找到先前的offset的值,即没有自动维护偏移量,也没有手动维护偏移量,则抛出异常

不自动进行 offset 重置,抛出 OffsetOutOfRangeException 异常

2. earliest

在各分区下有提交的offset时:从offset处开始消费

在各分区下无提交的offset时:从头开始消费

表示自动重置到 partition 的最小 offset

3. latest

在各分区下有提交的offset时:从offset处开始消费

在各分区下无提交的offset时:从最新的数据开始消费

默认为 latest,表示自动重置到 partition 的最大 offset

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐