此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.2.1Spring中文文档

此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.2.1Spring中文文档

概述和保证

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

话虽如此,对于处理单个分区的使用者来说,在大多数情况下,消息的处理应该大约在适当的时间进行。Spring中文文档

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