如果我有一个保留时间为 7 天的主题,并且将偏移量保留设置为 1 天,那么我最终可能会遇到这样的情况:如果 2 天后重新启动,消费者组将重新处理消息,因为偏移量已过期。(根据: https: //anshita-singh.medium.com/kafka-message-retention-vs-comfilled-offset-retention-c2359e3f9c5b)
反过来会发生什么?如果我的主题保留为 1 天,偏移保留为 7 天,那么当 Kafka 消费者启动时,它想要从尚不存在的位置读取。Kafka 是否能够优雅地处理这个问题?...或者,当向该主题发布消息时,它们不会被消费者读取,因为它的位置是遥远的未来吗?