跳到主要内容

暂停和恢复消费者

DeepSeek V3 中英对照 Pausing and Resuming the Consumer

如果您希望暂停消费但不导致分区重新平衡,您可以暂停和恢复消费者。这可以通过管理绑定生命周期来实现,如 Spring Cloud Stream 文档中的绑定可视化和控制所示,使用 State.PAUSEDState.RESUMED

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