响应式 Pulsar 客户端

目录

当您使用Reactive Pulsar Spring Boot Starter时,会自动配置ReactivePulsarClientspring-doc.cadn.net.cn

默认情况下,应用程序会尝试连接到本地的 Pulsar 实例,地址为 pulsar://localhost:6650。 可以通过设置 spring.pulsar.client.service-url 属性为其他值来调整该配置。spring-doc.cadn.net.cn

该值必须是一个有效的 Pulsar 协议 URL

有许多其他可用于配置的应用程序属性(继承自适配的命令式客户端)。 查看 spring.pulsar.client.* 应用程序属性。spring-doc.cadn.net.cn

1. 认证

要连接需要身份验证的 Pulsar 集群,请遵循 与命令式客户端相同 的步骤。 同样,这是因为 reactive 客户端会适配 imperative 客户端,该客户端处理所有安全配置。spring-doc.cadn.net.cn