响应式 Pulsar 客户端
目录
当你使用 Reactive Pulsar Spring Boot Starter 时,ReactivePulsarClient
将自动配置。
默认情况下,应用程序会尝试连接到本地的 Pulsar 实例,地址为 pulsar://localhost:6650
。你可以通过设置 spring.pulsar.client.service-url
属性来调整这个值。
提示
该值必须是一个有效的 Pulsar Protocol URL
还有许多其他应用程序属性(继承自适配的命令式客户端)可用于配置。请参阅 spring.pulsar.client.* 应用程序属性。
1. 认证
要连接到需要身份验证的 Pulsar 集群,请按照与命令式客户端相同的步骤进行操作。这是因为响应式客户端适配了处理所有安全配置的命令式客户端。