对于最新的稳定版本,请使用 spring-cloud-stream 4.3.0spring-doc.cadn.net.cn

概述

Spring Cloud Stream 包括一个专为 Apache Kafka Streams 绑定而设计的绑定器实现。 通过这种本机集成,Spring Cloud Stream“处理器”应用程序可以直接在核心业务逻辑中使用 Apache Kafka Streams API。spring-doc.cadn.net.cn

Kafka Streams 绑定器实现建立在 Spring for Apache Kafka 项目提供的基础之上。spring-doc.cadn.net.cn

Kafka Streams 绑定器为 Kafka Streams 中的三种主要类型提供了绑定功能 -KStream,KTableGlobalKTable.spring-doc.cadn.net.cn

Kafka Streams 应用程序通常遵循从入站主题读取记录的模型,应用业务逻辑,然后将转换后的记录写入出站主题。 或者,也可以定义没有出站目标的处理器应用程序。spring-doc.cadn.net.cn

在以下部分中,我们将详细介绍 Spring Cloud Stream 与 Kafka Streams 的集成。spring-doc.cadn.net.cn