Kafka auto.offset.reset earliest 和 latest简介

earliest和latest是 Kafka 消费者配置auto.offset.reset的两个核心选项，它们决定了当消费组没有已提交的偏移量（Offset）或偏移量失效时，从哪里开始消费。简单来说：earliest：从分区最早可用的消息开始消费，即从头开始。latest（默认值）：从分区最新的消息开始消费，即只消费新消息。⚙️ 触发条件与生效时机首先需要明确一个关键点：auto.offset.reset不是每次启动都生效。它只在以下两种特定情况下才会起作用：全新的消费者组：该消费者组第一次订阅这个主题，Kafka 中没有任何关于它的消费进度记录。已有的偏移量失效：消费者组的已提交偏移量因数据过期被删除，或该偏移量超出了当前日志范围（比如因为数据保留策略被清理）。一旦消费者组成功提交了偏移量，Kafka 就会严格遵循这个已提交的偏移量，auto.offset.reset配置将不会再产生任何影响。📊earliestvslatest核心区别配置项行为适用场景潜