|
这个版本仍在开发中,目前尚未被认为是稳定的。要使用最新稳定版本,请使用 Spring for Apache Kafka 4.0.4! |
后退延迟精度
概述与保证
所有消息处理和回退都由消费者线程处理,因此在尽力而为的基础上保证延迟精度。 如果一条消息的处理时间比该消费者下下条消息的回退间隔长,那么下条消息的延迟将高于预期。 此外,对于短延迟(约1秒或以下),线程需要进行的维护工作(如提交偏移量),可能会延迟消息处理的执行。 如果重试主题的消费者正在处理多个分区,延迟精度也会受到影响,因为我们依赖于从轮询中唤醒消费者并拥有完整的pollTimeouts来进行时间调整。
也就是说,对于处理单个分区消息的消费者,在大多数情况下,消息的处理应该大致在确切的到期时间进行。
| 可以保证消息绝不会在到期时间之前被处理。 |