kafka-python中消费参数auto.offset.reset详解
kafka中没有offset时，不论是什么原因，offset没了，这是auto.offset.reset配置就会起作用。如果没有为消费者找到先前的offset的值,即没有自动维护偏移量,也没有手动维护偏移量,则抛出异常不自动进行 offset 重置，抛出 OffsetOutOfRangeException 异常。
·
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
华为开发者空间，是为全球开发者打造的专属开发空间，汇聚了华为优质开发资源及工具，致力于让每一位开发者拥有一台云主机，基于华为根生态开发、创新。
更多推荐
0
0- 0
已为社区贡献37条内容
所有评论(0)