|
对于最新稳定版本，请使用spring-cloud-stream 5.0.1！ |
概述
| 自 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 应用程序使用反应类型（Flux、Mono 等）编写时，建议使用此响应式 Kafka 绑定器而不是常规的消息通道基础 Kafka 绑定器。