概覽

Spring Cloud Stream 包含一個專門為 Apache Kafka Streams 繫結設計的 Binder 實現。透過這種原生整合，Spring Cloud Stream 的“處理器”應用可以在核心業務邏輯中直接使用 Apache Kafka Streams API。

Kafka Streams Binder 實現構建在 Spring for Apache Kafka 專案提供的基礎之上。

Kafka Streams Binder 為 Kafka Streams 中的三種主要型別提供了繫結能力：KStream、KTable 和 GlobalKTable。

Kafka Streams 應用通常遵循一種模型：從入站主題讀取記錄，應用業務邏輯，然後將轉換後的記錄寫入出站主題。此外，也可以定義一個沒有出站目標的處理器應用。

在以下章節中，我們將詳細介紹 Spring Cloud Stream 與 Kafka Streams 的整合。