kafka之consumer参数auto.offset.reset

本文转载自查看原文 2022-03-17 11:33 923 kafka

auto.offset.reset：可理解为kafka consumer读取数据的策略，本地用的kafka版本为0.10，因此该参数可填earliest|latest|none。

earliest：当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费
latest：当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，消费新产生的该分区下的数据
none： topic各分区都存在已提交的offset时，从offset后开始消费；只要有一个分区不存在已提交的offset，则抛出异常

免责声明！

本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。

猜您在找 kafka之consumer参数auto.offset.reset 0.10+ kafka学习总结015 --- consumer配置参数之auto.offset.reset Kafka auto.offset.reset值详解 kafka auto.offset.reset latest earliest 详解 kafka auto.offset.reset latest earliest 详解 kafka_2.11-0.10.2.1中的auto.offset.reset Kafka(二)关于Kafka设置(spring.kafka.consumer.enable-auto-commit=false)依然提交消息确认的offset问题分析。 kafka consumer 自动提交 offset kafka consumer 指定 offset，进行消息回溯 kafka 关于offset的理解--关于__consumer_offsets分析