概述

从 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 绑定器。spring-doc.cadn.net.cn