概述

Spring Cloud Stream 中的 Kafka Binder 生态系统提供了一个专门的反应式 Binder,该 Binder 基于 Reactor Kafka 项目。此反应式 Kafka Binder 可以在基于 Apache Kafka 的应用程序中启用端到端的反应式功能,例如反压、反应式流等。当使用反应式类型(FluxMono 等)编写 Spring Cloud Stream Kafka 应用程序时,建议使用此反应式 Kafka Binder,而不是基于常规消息通道的 Kafka Binder。