这家伙太懒,什么都没留下
应该是文件句柄没有正常释放,由于某些程序还在占用,导致文件并没有真正删除,所以消费还能消费到。
用 lsof | grep deleted 查看是否有对应的kafka日志文件,应该就能判断。
过期策略是正常的, 就是不知道为什么数据过期之后, 消费端还能消费到o(╥﹏╥)o
那就是说,现在你的kafka集群数据过期策略一切正常,不会查到3天前的数据。
时间是正常的, 跟系统时间完全一致, 消费者commit timestamp也是正确的
你现在查看,返回的数据,时间是否是正常的呢?