このバージョンはまだ開発中であり、まだ安定しているとは考えられていません。最新の安定バージョンについては、spring-cloud-stream 5.0.3 を使用してください。 |
インスタンスインデックスとインスタンス数
Spring Cloud Stream アプリケーションをスケールアップすると、各インスタンスは、同じアプリケーションの他のインスタンスがいくつ存在するか、およびそれ自体のインスタンスインデックスが何であるかに関する情報を受け取ることができます。Spring Cloud Stream は、spring.cloud.stream.instanceCount および spring.cloud.stream.instanceIndex プロパティを介してこれを行います。例: HDFS シンクアプリケーションのインスタンスが 3 つある場合、3 つのインスタンスすべてで spring.cloud.stream.instanceCount が 3 に設定され、個々のアプリケーションで spring.cloud.stream.instanceIndex がそれぞれ 0、1、2 に設定されます。
Spring Cloud Stream アプリケーションが Spring Cloud Data Flow を介してデプロイされると、これらのプロパティは自動的に構成されます。Spring Cloud Stream アプリケーションを個別に起動する場合は、これらのプロパティを正しく設定する必要があります。デフォルトでは、spring.cloud.stream.instanceCount は 1 であり、spring.cloud.stream.instanceIndex は 0 です。
スケールアップされたシナリオでは、これら 2 つのプロパティの正しい構成は、一般にパーティショニング動作(以下を参照)に対処するために重要であり、データを確保するために、特定のバインダー(Kafka バインダーなど)では常に 2 つのプロパティが必要です。複数のコンシューマーインスタンスに正しく分割されます。