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