概述

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 的集成。