暫停和恢復消費者
如果您希望暫停消費但不想引起分割槽重新平衡,您可以暫停和恢復消費者。這可以透過管理繫結生命週期來實現,如 Spring Cloud Stream 文件中 繫結視覺化和控制 一節所示,使用 State.PAUSED
和 State.RESUMED
狀態。
要恢復消費,您可以使用 ApplicationListener
(或 @EventListener
方法)來接收 ListenerContainerIdleEvent
例項。事件釋出的頻率由 idleEventInterval
屬性控制。