概述
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(英国可爱的)音乐和全球可爱.
Kafka Streams 应用通常遵循一种模式:从入站主题读取记录,应用业务逻辑,然后将转换后的记录写入出站主题。 或者,也可以定义一个没有出站目的地的处理器应用程序。
在接下来的章节中,我们将详细介绍 Spring Cloud Stream 与 Kafka Streams 的集成。