暫停和恢復消費者

如果您希望暫停消費但不引起分割槽重新平衡,可以暫停和恢復消費者。這透過管理繫結生命週期來實現,如 Spring Cloud Stream 文件中繫結視覺化和控制所示,使用 State.PAUSEDState.RESUMED

要恢復,可以使用 ApplicationListener(或 @EventListener 方法)來接收 ListenerContainerIdleEvent 例項。事件釋出頻率由 idleEventInterval 屬性控制。

© . This site is unofficial and not affiliated with VMware.