概述
|
从 Spring Cloud Stream 4.3.0 版本开始，响应式 Kafka 绑定器已被弃用，并将在未来的版本中完全移除。请参阅 Reactor Kafka 已停用博客文章 中的相关更新。请继续使用基于常规消息通道的 Kafka 绑定器和响应式类型。请记住，应用程序需要使用 Reactor 编程模型和 Project Reactor 的直接支持来明确处理各种响应式用例。 |
Spring Cloud Stream 中的 Kafka 绑定器生态系统提供了一个基于 Reactor Kafka 项目的专用响应式绑定器。
这个响应式 Kafka 绑定器支持 Apache Kafka 应用程序中的完整端到端响应式功能，例如背压、响应式流等。
当您的 Spring Cloud Stream Kafka 应用程序使用响应式类型（Flux、Mono 等）编写时，建议使用这个响应式 Kafka 绑定器，而不是基于常规消息通道的 Kafka 绑定器。