响应式 Pulsar 客户端

目录

当您使用 Reactive Pulsar Spring Boot Starter 时,您将获得ReactivePulsarClient自动配置。spring-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 集群,请按照与命令式客户端相同的步骤进行作。 同样,这是因为响应式客户端适配了处理所有安全配置的命令式客户端。spring-doc.cadn.net.cn