此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.3.0spring-doc.cn

Back Off Delay 精度

概述和保证

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

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

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