概覽

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

Kafka Streams 繫結器實現建立在 Spring for Apache Kafka 專案提供的基礎之上。

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

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

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