概述

Spring Cloud Stream 中的 Kafka binder 生态系统基于 Reactor Kafka 项目提供了一个专用的响应式 binder。此响应式 Kafka binder 使基于 Apache Kafka 的应用能够获得完整的端到端响应式能力，例如背压、响应式流等。当你的 Spring Cloud Stream Kafka 应用使用响应式类型（Flux, Mono 等）编写时，建议使用此响应式 Kafka binder，而不是基于常规消息通道的 Kafka binder。