暂停和恢复消费者

如果希望暂停使用但不导致分区重新平衡,则可以暂停和恢复使用。 这可以通过管理绑定生命周期来促进,如 Spring Cloud Stream 文档中的绑定可视化和控制所示,使用State.PAUSEDState.RESUMED.spring-doc.cadn.net.cn

要恢复,您可以使用ApplicationListener(或@EventListener方法)接收ListenerContainerIdleEvent实例。 事件发布的频率由idleEventInterval财产。spring-doc.cadn.net.cn