关于为Pulsar Client配置AutoClusterFailover的技术咨询

Spring for Apache Pulsar 支持集群故障转移配置，它底层完全复用Apache Pulsar原生客户端的故障转移能力，只是0.1.0-M1这个早期里程碑版本的文档没有单独对这块做详细说明。

配置方式 #

1. 通过配置文件（application.yml/properties）

直接使用Spring Pulsar的客户端配置前缀，传递Pulsar原生的故障转移相关参数：

• 基础故障转移地址配置：

spring:
  pulsar:
    client:
      service-url: "failover://broker1:6650,broker2:6650,broker3:6650"

• 进阶参数配置（比如重试次数、切换延迟等）：

spring:
  pulsar:
    client:
      service-url: "failover://broker1:6650,broker2:6650"
      properties:
        failover-max-redirects: 5
        failover-sleep-between-retries-ms: 1000

2. 通过Java代码自定义客户端

如果需要更灵活的配置，可以实现PulsarClientCustomizer来定制客户端实例：

@Configuration
public class PulsarConfig {
    @Bean
    public PulsarClientCustomizer pulsarClientCustomizer() {
        return clientBuilder -> {
            // 配置故障转移服务地址
            clientBuilder.serviceUrl("failover://broker1:6650,broker2:6650");
            // 可选：设置故障转移相关参数
            clientBuilder.setMaxRedirects(5);
            clientBuilder.setFailoverSleepBetweenRetriesMs(1000);
        };
    }
}

注意事项 #

• 故障转移地址的格式遵循Pulsar原生规范：failover://<broker-url-list>，多个broker用逗号分隔。
• 0.1.0-M1作为早期里程碑版本，部分配置参数的前缀或名称可能在后续正式版中有所调整，建议结合对应版本的Apache Pulsar客户端文档来确认参数细节。

内容的提问来源于stack exchange，提问作者Suzy