Apache Pulsar连接握手失败求助：无法获取分区主题元数据

可能的原因及对应解决方案 #

1. Service URL 配置错误 #

你代码中使用的<my pulsar web url>大概率是Pulsar Web UI的地址（通常为8080/8443端口），但客户端连接需要使用Broker的服务端口：

• 明文连接用 pulsar://<broker公网IP>:6650
• TLS加密连接用 pulsar+ssl://<broker公网IP>:6651

修改代码中的serviceUrl：

PulsarClient client = PulsarClient.builder()
    .serviceUrl("pulsar://xxx.xxx.xxx.xxx:6650") // 替换为你的Broker公网IP
    .build();

2. AWS 安全组与网络配置问题 #

即使关闭了防火墙，AWS安全组规则仍会限制端口访问：

• 检查Broker所在EC2实例的安全组，添加入站规则：允许你的客户端IP访问6650（或6651）端口
• 如果使用了负载均衡，确认负载均衡已正确转发6650/6651端口到Broker实例，且健康检查未将Broker标记为不健康
• 重点检查Broker的advertisedAddress配置：在conf/broker.conf中，该参数必须设置为客户端能访问的公网IP/域名，否则Broker会返回内部私有IP给客户端，导致连接断开

3. Pulsar Broker 配置问题 #

登录Broker节点，检查conf/broker.conf的关键配置：

• listeners：确保包含对外监听地址，例如 listeners=pulsar://0.0.0.0:6650
• 如果启用了TLS，客户端需要额外配置TLS参数：

  PulsarClient client = PulsarClient.builder()
      .serviceUrl("pulsar+ssl://xxx.xxx.xxx.xxx:6651")
      .enableTls(true)
      .tlsTrustCertsFilePath("/path/to/trust-cert.pem")
      .build();
  

4. 客户端代码异常捕获优化 #

当前代码未完整打印异常堆栈，建议添加捕获逻辑以获取更详细的错误信息：

public static void main(String[] args) {
    try {
        PulsarClient client = PulsarClient.builder()
            .serviceUrl("pulsar://xxx.xxx.xxx.xxx:6650")
            .build();
        
        Producer<String> producer = client.newProducer(Schema.STRING)
            .topic("my-topic")
            .create();

        producer.newMessage()
            .value("HelloWorld")
            .send();

        producer.close();
        client.close();
    } catch (PulsarClientException e) {
        e.printStackTrace();
    }
}

快速排查步骤 #

1. 用nc或telnet测试客户端到Broker端口的连通性：

   nc -zv xxx.xxx.xxx.xxx 6650
   

2. 登录Broker节点，查看Broker日志（logs/broker.log），确认是否有连接失败的详细原因
3. 验证advertisedAddress配置是否与Broker公网IP一致

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