本站内所有文档均为中英对照文档，点击中文可以显示英文。此提醒连续关闭5次后，将不再显示。

文档内容来源于 spring.io，由 springdoc.tech 翻译，版权归属于 SPRING.IO (Broadcom. Inc)。可供个人学习、研究，未经许可，不得进行转载或用于商业行为。

概述

DeepSeek V3 中英对照 Overview

Spring Cloud Stream 包含一个专门为 Apache Kafka Streams 绑定设计的 binder 实现。通过这种原生集成，Spring Cloud Stream 的 "processor" 应用程序可以直接在核心业务逻辑中使用 Apache Kafka Streams 的 API。

Kafka Streams 绑定器实现建立在 Spring for Apache Kafka 项目提供的基础之上。

Kafka Streams 绑定器为 Kafka Streams 中的三种主要类型提供了绑定功能 - KStream、KTable 和 GlobalKTable。

Kafka Streams 应用程序通常遵循一种模型，其中记录从入站主题读取，应用业务逻辑，然后将转换后的记录写入出站主题。或者，也可以定义一个没有出站目的地的 Processor 应用程序。

在接下来的章节中，我们将详细探讨 Spring Cloud Stream 与 Kafka Streams 的集成细节。