此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 spring-cloud-stream 4.1.4! |
暂停和恢复使用者
如果您希望暂停消费但不会导致分区重新平衡,则可以暂停和恢复使用者。
这是通过管理绑定生命周期来实现的,如 Spring Cloud Stream 文档中的 绑定可视化和控制 所示,使用State.PAUSED
和State.RESUMED
.
要恢复,您可以使用ApplicationListener
(或@EventListener
方法)接收ListenerContainerIdleEvent
实例。
事件的发布频率由idleEventInterval
财产。