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