跳到主要内容
版本:5.0.1

暂停与恢复消费者

DeepSeek V3 中英对照 Pausing and Resuming the Consumer

如果您希望暂停消费但又不触发分区再平衡,可以通过暂停和恢复消费者来实现。这可以通过管理绑定生命周期来完成,如Spring Cloud Stream文档中的绑定可视化与控制部分所示,使用State.PAUSED和State.RESUMED状态。

总而言之,你可以使用一个 ApplicationListener(或 @EventListener 方法)来接收 ListenerContainerIdleEvent 实例。事件发布的频率由 idleEventInterval 属性控制。