版本：5.0.1

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

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

概述

DeepSeek V3 中英对照 Overview

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

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

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

Kafka Streams 应用程序通常遵循这样的模型：从输入主题读取记录，应用业务逻辑，然后将转换后的记录写入输出主题。或者，也可以定义一个没有输出目标的处理器应用程序。

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