最新の安定バージョンについては、spring-cloud-stream 5.0.2 を使用してください。

概要

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

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