微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐