概要

Spring Cloud Stream には、Apache Kafka ストリーム (英語) バインディング用に明示的に設計されたバインダー実装が含まれています。このネイティブ統合により、Spring Cloud Stream「プロセッサー」アプリケーションはコアビジネスロジックで Apache Kafka ストリーム (英語) API を直接使用できます。

Kafka Streams バインダーの実装は、Spring for Apache Kafka プロジェクトによって提供される基盤上に構築されています。

Kafka Streams バインダーは、Kafka Streams の 3 つの主要な型である KStream、KTable、GlobalKTable のバインディング機能を提供します。

Kafka Streams アプリケーションは通常、レコードが受信トピックから読み取られ、ビジネスロジックを適用してから、変換されたレコードを送信トピックに書き込むモデルに従います。または、送信先のないプロセッサーアプリケーションを定義することもできます。

次のセクションでは、Spring Cloud Stream と Kafka ストリームの統合の詳細を見ていきます。