暂停和恢复消费者

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

要恢复,您可以使用ApplicationListener(或@EventListener方法)来接收ListenerContainerIdleEvent实例。事件发布的频率由idleEventInterval属性控制。