概览

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 应用通常遵循一种模型：从入站主题读取记录，应用业务逻辑，然后将转换后的记录写入出站主题。此外，也可以定义一个没有出站目标的处理器应用。

在以下章节中，我们将详细介绍 Spring Cloud Stream 与 Kafka Streams 的集成。