Kafka如何处理在使用者偏移量位于段文件内的情况下保留期限到期的情况？

如何解决Kafka如何处理在使用者偏移量位于段文件内的情况下保留期限到期的情况？

我想知道卡夫卡如何处理这种情况。消费者遇到了毒药消息，并且没有越过它。很长一段时间（15天）没有人注意到。该主题的保留期为（7天）。假设该毒药已保存在日志段文件中，该文件已满足保留期要删除的要求。

会发生什么？

1. 当使用者积极尝试从中读取文件时，Kafka是否允许删除此日志段文件？
2. Kafka是否会删除日志段文件，而让使用者争先恐后地尝试使用auto.offset.reset设置来找出从何处开始读取？

解决方法

这将是选项2，您可以在使用者实例上找到指示其正在寻找开始/结束的日志，如果自动偏移量重置=无表示偏移量超出范围，则会失败