並行性

リアクティブ Kafka バインダーでリアクティブ関数を使用する場合、コンシューマーバインディングに同時実行を設定すると、バインダーは同時実行値によって提供される数の専用 KafkaReceiver オブジェクトを作成します。つまり、これにより、個別の Flux 実装で複数のリアクティブストリームが作成されます。これは、分割されたトピックからレコードを使用する場合に役立ちます。

例: 受信トピックに少なくとも 3 つのパーティションがあるとします。次に、次のプロパティを設定できます。

これにより、3 つの個別の Flux 実装を生成し、ハンドラーメソッドにストリーミングする 3 つの専用 KafkaReceiver オブジェクトが作成されます。