kafka-python中消费参数auto.offset.reset详解

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