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