概觀
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 的整合細節。