如果Kafka主题中的事件因保留策略而过期，是否有任何机制（通过特定日志文件条目或类似方式）获得通知(我知道这应该通过设计避免，但仍然是）。
我知道用于监视已发布事件和相关消费者组之间的偏移差异的消费者滞后监视工具，但它们只提供了一个AIK数字（偏移差异）。
换言之：我们如何才能发现Kafka事件是否从未被消费，因此过期？