此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 spring-cloud-stream 4.1.4spring-doc.cadn.net.cn

暂停和恢复使用者

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

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