本地Minikube部署Pulsar后Python创建生产者出现连接超时或拒绝错误

• 客户端连接协议使用错误：Pulsar官方Python客户端和Broker通信默认使用pulsar://二进制协议，你代码中全填写了http://开头的地址，该协议仅适用于Pulsar Admin API调用，无法用于客户端和Broker的原生通信，这是核心错误点。
• 端口对应关系混淆：你给出的Service端口配置中，http/80是Pulsar Admin服务端口，pulsar/6650才是客户端和Broker通信的专属服务端口，二者不能混用。
• Minikube隧道端口映射未匹配：启动隧道后输出的两个本地端口，分别对应Admin 80端口和Broker 6650端口，用错对应关系也会导致连接失败。

• 先确认隧道端口映射：在开启minikube隧道的终端查看输出日志，确认两个本地端口的对应关系，常规场景下你案例中的127.0.0.1:50069对应Admin 80端口，127.0.0.1:50070对应Broker 6650端口。
• 手动验证端口可达性：执行curl http://127.0.0.1:50069/admin/v2/brokers/ids验证Admin端口可通，正常会返回集群Broker ID列表；执行telnet 127.0.0.1 50070验证Broker端口可通，能建立连接说明端口暴露正常。
• 确认集群状态：执行kubectl -n pulsar get pods确认所有Pulsar组件都处于Running状态，无异常重启。

修改Python代码的连接协议为pulsar://，地址指向Broker对应端口即可：

import pulsar

# 协议使用pulsar://，端口指向映射到Broker 6650的本地端口50070
client = pulsar.Client('pulsar://127.0.0.1:50070')
producer = client.create_producer('persistent://public/default/my-topic', block_if_queue_full=True, batching_enabled=True, batching_max_publish_delay_ms=10)
# 测试消息发送
producer.send(b'test message')
print("消息发送成功")
client.close()

如果你不想使用隧道，可直接使用NodePort访问，连接地址填写pulsar://192.168.49.2:30841即可，该端口是Broker 6650对应的NodePort。

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