假设源系统/生产者/kafka集群之间存在一些故障或延迟，这会导致延迟的补偿到达消费者。如果发生这种情况，那么到达目标系统的数据将不再是真实的。
那你怎么去掉这些“旧的”补偿？？
一些系统必须尽可能实时，即使某些偏移量被删除，这一点也很关键。
谢谢您！