此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.3.9spring-doc.cadn.net.cn

回退延迟精度

概述和保证

所有消息处理和回退都由使用者线程处理,因此,延迟精度在尽最大努力的基础上得到保证。 如果一条消息的处理时间长于该使用者的下一条消息的回退期,则下一条消息的延迟将高于预期。 此外,对于短延迟(大约 1 秒或更短),线程必须执行的维护工作(例如提交偏移量)可能会延迟消息处理的执行。 如果重试主题的使用者正在处理多个分区,精度也会受到影响,因为我们依赖于从轮询中唤醒使用者并具有完整的 pollTimeouts 来进行计时调整。spring-doc.cadn.net.cn

话虽这么说,对于处理单个分区的使用者,在大多数情况下,消息的处理应该大约在其确切的到期时间进行。spring-doc.cadn.net.cn

可以保证消息永远不会在到期时间之前得到处理。