该框架为几乎所有支持的功能提供了响应式对应物。

如果你把这个词放在一个提供的命令式组件的前面,你可能会发现它的响应式对应物。Reactive

  • PulsarTemplate → ReactivePulsarTemplate

  • PulsarListener → ReactivePulsarListener

  • PulsarConsumerFactory → ReactivePulsarConsumerFactory

  • 等。。

但是,尚不支持以下内容:

  • 非共享订阅中的错误处理

  • 在流模式下访问 Pulsar 标头@Header

  • 观察

如果你把这个词放在一个提供的命令式组件的前面,你可能会发现它的响应式对应物。Reactive

  • PulsarTemplate → ReactivePulsarTemplate

  • PulsarListener → ReactivePulsarListener

  • PulsarConsumerFactory → ReactivePulsarConsumerFactory

  • 等。。

前言

对于基于 Apache Pulsar 的应用程序,我们建议对 Spring 使用 Spring-Boot-First 方法,因为这极大地简化了事情。 为此,您可以将模块添加为依赖项。spring-pulsar-reactive-spring-boot-starter
本参考的大部分内容都希望读者使用启动器,并给出了大多数配置说明,并牢记这一点。 但是,当指令特定于 Spring Boot 入门器用法时,会努力调用。
对于基于 Apache Pulsar 的应用程序,我们建议对 Spring 使用 Spring-Boot-First 方法,因为这极大地简化了事情。 为此,您可以将模块添加为依赖项。spring-pulsar-reactive-spring-boot-starter
本参考的大部分内容都希望读者使用启动器,并给出了大多数配置说明,并牢记这一点。 但是,当指令特定于 Spring Boot 入门器用法时,会努力调用。