Kafka消费者配置auto.offset.reset设为latest时是否包含主题最后一条事件?
Kafka 消费者配置
auto.offset.reset 详解 配置可选值
earliestlatestnone
触发配置生效的场景
当消费者组没有可用的已提交偏移量时,该配置会用于初始化偏移量,常见触发场景包括:
- Broker 从未见过该
group.id(比如新消费者组首次连接,或同一group.id的消费者组之前连接但从未提交过偏移量) - Broker 已将旧的提交偏移量垃圾回收(默认回收周期为7天)
- 对应已提交偏移量的消息日志部分因超过保留时间或大小限制被垃圾回收
不同配置值的行为
- 设置为
none:无历史偏移量时直接抛出异常 - 设置为
earliest:会从主题最开始的位置读取所有事件 - 设置为
latest:偏移量会被设置为主题当前末尾位置之后,消费者不会消费已有的任何消息,只能等待后续生产者写入新消息后才能开始消费。
举个直观例子:假设当前主题最后一条消息的偏移量是100,设置latest后,消费者的起始偏移量会是101——只有当偏移量为101、102...的新消息产生时,消费者才会读取这些新消息,已有的1-100号消息不会被消费。
内容的提问来源于stack exchange,提问作者user2138149
相关产品推荐
相关产品推荐

