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