最新の安定バージョンについては、spring-cloud-stream 4.2.1 を使用してください。 |
コンシューマーの一時停止と再開
消費を一時停止したいが、パーティションのリバランスを引き起こしたくない場合は、コンシューマーを一時停止して再開できます。これは、State.PAUSED
および State.RESUMED
を使用して、Spring Cloud Stream ドキュメントの結合の視覚化と制御に示されているようにバインディングライフサイクルを管理することによって容易になります。
再開するには、ApplicationListener
(または @EventListener
メソッド)を使用して ListenerContainerIdleEvent
インスタンスを受信できます。イベントが公開される頻度は、idleEventInterval
プロパティによって制御されます。