这个版本仍在开发中,尚未达到稳定状态。要使用最新稳定版,请使用 spring-cloud-stream 5.0.1 spring-doc.cadn.net.cn

概述

自 Spring Cloud Stream 4.3.0 版本起,reactive Kafka 绑定器已弃用,并将在未来的某个发布中完全移除。有关相关内容,请参阅 Reactor Kafka 停用博客。请继续使用基于普通消息通道的 Kafka 绑定器(使用 reactive 类型)。请注意,应用程序需要使用 Project Reactor 提供的支持,显式处理各种 reactive 使用场景,并采用响应式编程模型(Reactor 模型)。

Kafka 绑定生态系统在 Spring Cloud Stream 中提供了基于 Reactor Kafka 项目的专用响应式绑定器。
此响应式 Kafka 绑定器使基于 Apache Kafka 的应用程序能够实现完整的端到端响应式功能,例如背压、响应式流等。
当您的 Spring Cloud Stream Kafka 应用程序使用反应类型(FluxMono 等)编写时,建议使用此响应式 Kafka 绑定器而不是常规的消息通道基础 Kafka 绑定器。spring-doc.cadn.net.cn