问题描述
我想知道卡夫卡如何处理这种情况。消费者遇到了毒药消息,并且没有越过它。很长一段时间(15天)没有人注意到。该主题的保留期为(7天)。假设该毒药已保存在日志段文件中,该文件已满足保留期要删除的要求。
会发生什么?
- 当使用者积极尝试从中读取文件时,Kafka是否允许删除此日志段文件?
- Kafka是否会删除日志段文件,而让使用者争先恐后地尝试使用
auto.offset.reset
设置来找出从何处开始读取?
解决方法
这将是选项2,您可以在使用者实例上找到指示其正在寻找开始/结束的日志,如果自动偏移量重置=无表示偏移量超出范围,则会失败