概要

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