|
此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 spring-cloud-stream 4.1.4！ |
概述
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 应用程序通常遵循一个模型，在该模型中，从入站主题中读取记录，应用业务逻辑，然后将转换后的记录写入出站主题。 或者，也可以定义没有出站目标的 Processor 应用程序。
在以下部分中，我们将了解 Spring Cloud Stream 与 Kafka Streams 集成的详细信息。