概要

Spring Cloud Stream バージョン 4.3.0 以降、リアクティブ Kafka バインダーは非推奨となり、将来のリリースで完全に削除されます。Reactor Kafka 廃止ブログ投稿 (英語) の関連アップデートを参照してください。リアクティブ型を使用する通常のメッセージチャネルベースの Kafka バインダーを引き続きご利用ください。アプリケーションは、リアクタープログラミングモデルとプロジェクト Reactor のサポートを直接使用して、さまざまなリアクティブユースケースを明示的に処理する必要があることにご注意ください。

Spring Cloud Stream の Kafka バインダーエコシステムは、Reactor Kafka (英語) プロジェクトに基づいた専用のリアクティブバインダーを提供します。このリアクティブ Kafka バインダーは、Apache Kafka ベースのアプリケーションにおいて、バックプレッシャーやリアクティブストリームといったエンドツーエンドのリアクティブ機能を完全に実現します。Spring Cloud Stream/Kafka アプリケーションがリアクティブ型(FluxMono など)を使用して記述されている場合は、通常のメッセージチャネルベースの Kafka バインダーではなく、このリアクティブ Kafka バインダーを使用することをお勧めします。