Pausing and Resuming the Consumer
如果您希望暂停消耗,但不导致分区重新平衡,则可以暂停并恢复使用者。这可以通过管理 Spring Cloud Stream 文档中的 绑定可视化和控制 中显示的绑定的生命周期,使用 State.PAUSED
和 State.RESUMED
来实现。
要恢复,您可以使用 ApplicationListener
(或 @EventListener
方法)来接收 ListenerContainerIdleEvent
实例。发布事件的频率由 idleEventInterval
属性控制。