如果我有一个保留时间为 7 天的主题,并且将偏移量保留设置为 1 天,那么我最终可能会遇到这样的情况:如果 2 天后重新启动,消费者组将重新处理消息,因为偏移量已过期。(根据: https: //anshita-singh.medium.com/kafka-message-retention-vs-comfilled-offset-retention-c2359e3f9c5b)
反过来会发生什么?如果我的主题保留为 1 天,偏移保留为 7 天,那么当 Kafka 消费者启动时,它想要从尚不存在的位置读取。Kafka 是否能够优雅地处理这个问题?...或者,当向该主题发布消息时,它们不会被消费者读取,因为它的位置是遥远的未来吗?
对于一个全新的消费群体或者当请求越界抵消时,该
auto.offset.reset
属性就会生效。默认情况下,它将从主题末尾开始消耗。然而,“还”这个词其实并没有什么意义。偏移量不断增加。你必须明确请求一个比现有的更大的