该版本仍在开发中,尚未被视为稳定。对于最新稳定版本,请使用 spring-cloud-stream 5.0.0!spring-doc.cadn.net.cn

概述

自 Spring Cloud Stream 4.3.0 版本起,响应式 Kafka 绑定器已被弃用,未来版本将完全移除。请参见“反应堆卡夫卡已停刊”博客文章中的相关更新。请继续使用基于消息频道的常规Kafka活页夹,带有响应式。请记住,应用程序需要明确使用反应堆编程模型和项目反应堆的支持来处理各种响应式用例。

Spring Cloud Stream中的Kafka绑定器生态系统基于Reactor Kafka项目,提供了一个专用的响应式绑定器。 该响应式Kafka绑定器支持基于Apache Kafka的应用中的端到端响应功能,如背压、反应流等。 当你的 Spring Cloud Stream Kafka 应用程序使用响应式类型编写时(通量,等等),建议使用这个响应式Kafka活页夹,而不是基于消息通道的普通Kafka活页夹。spring-doc.cadn.net.cn