SpringCloud Kafka流Binder概述

2023-11-28 16:36 更新

Spring Cloud Stream的Apache Kafka支持還包括為Apache Kafka流綁定顯式設計的綁定器實現(xiàn)。通過這種本機集成，Spring Cloud Stream“處理器”應用程序可以直接在核心業(yè)務邏輯中使用 Apache Kafka Streams API。

Kafka Streams活頁夾實現(xiàn)基于Spring Kafka 項目中的Kafka Streams提供的基礎(chǔ)。

Kafka Streams綁定器為Kafka Streams中的三種主要類型（KStream，KTable和GlobalKTable）提供了綁定功能。

作為本機集成的一部分， Kafka Streams API提供的高級Streams DSL可用于業(yè)務邏輯。

還提供處理器API支持的早期版本。

如早期所述，Spring Cloud Stream中的Kafka流支持僅在處理器模型中嚴格可用?？梢詰靡环N模型，在該模型中，可以從入站主題讀取消息，進行業(yè)務處理，然后可以將轉(zhuǎn)換后的消息寫入出站主題。它也可以用于無出站目的地的處理器應用程序中。


以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號