概览

从 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 绑定器。