並行性
リアクティブ Kafka バインダーでリアクティブ関数を使用する場合、コンシューマーバインディングに同時実行を設定すると、バインダーは同時実行値によって提供される数の専用 KafkaReceiver
オブジェクトを作成します。つまり、これにより、個別の Flux
実装で複数のリアクティブストリームが作成されます。これは、分割されたトピックからレコードを使用する場合に役立ちます。
例: 受信トピックに少なくとも 3 つのパーティションがあるとします。次に、次のプロパティを設定できます。
spring.cloud.stream.bindings.lowercase-in-0.consumer.concurrency=3
これにより、3 つの個別の Flux
実装を生成し、ハンドラーメソッドにストリーミングする 3 つの専用 KafkaReceiver
オブジェクトが作成されます。