问题描述
我试图了解，ConsumerConfig.auto.offset.reset = Latest将如何影响消息使用.
I'm trying to understand, how does the ConsumerConfig.auto.offset.reset = latest would affect the message consumption.
例如，我有一个使用者，最初在时间t1发送100条消息，然后我的使用者在t1 + 30秒启动并运行，然后我的使用者会消耗t1 + 30秒之后发布的消息，还是会消耗消息从t1开始发布?
For example I've a consumer, sending 100 messages initially at time t1 and then my consumer is up and running at t1+30 sec, then would my consumer consume the messages published after t1+30 sec or will it consume messages published t1 onwards?
推荐答案
这要视情况而定.
auto.offset.reset 仅在没有为使用者组存储偏移量的情况下适用.
auto.offset.reset only applies when there is no stored offset for the consumer group.
它适用于以下条件:
- 消费群体第一次消费
- 如果使用者未提交任何补偿，则在下次启动时
- 如果某个消费群体已过期(现代经纪人默认为7天)
- 如果由于消息保留策略已删除了存储的偏移量指向的消息(尝试读取已清除的消息会触发规则的应用)
如果消费者承诺补偿；它将在下一次启动时从最后提交的偏移量开始.
If a consumer commits an offset; it will start at the last committed offset the next time it is started.
这篇关于Kafka Consumer配置-auto.offset.reset如何控制消息使用的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！