概述

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