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