概述

Spring Cloud Stream 中的 Kafka Binder 生态系统提供了基于 Reactor Kafka 项目的专用响应式 Binder。 这种响应式 Kafka Binder 在基于 Apache Kafka 的应用程序中支持完整的端到端响应式功能,例如背压、响应式流等。 当您使用响应式类型 (Flux,Mono等),建议使用这个响应式 Kafka Binder 而不是基于常规消息通道的 Kafka Binder。spring-doc.cadn.net.cn