Pausing and Resuming the Consumer

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

要恢复,您可以使用 ApplicationListener(或 @EventListener 方法)来接收 ListenerContainerIdleEvent 实例。发布事件的频率由 idleEventInterval 属性控制。