apache / apache/pulsar-client-python

`use_tls` and `pulsar+ssl://` client behavior can differ

未關閉
#269 1 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
主要語言
Python
星號
75
分支
53
PR 合併指標
30 天內沒有已合併 PR

描述

While running Pulsar cluster proxies behind an AWS Load Balancer I ran into issues with TLS connections to the proxies using example code from this repository. Running the `examples/consumer.py` code with the client url set to an LB hostname and `use_tls=True` results in connection failures, whereas simply specifying `pulsar+ssl://` the consumer works as expected. After checking [docs ](https://pulsar.apache.org/api/python/3.8.x/pulsar.Client.html)it seems the `use_tls` argument is deprecated, but I would still expect the behavior between `use_tls` and `pulsar+ssl://` to be the same. I can provide details on the load balancer configuration if needed.

Examples with some logs (fake hostname):
```python
client = pulsar.Client("pulsar://pulsar-primary.acme.org:6651", use_tls=True)
```
This client produces connection errors like below:
```
2025-10-10 12:56:28.815 INFO [0x1f7cd60c0] Client:86 | Subscribing on Topic < redacted_topic >
2025-10-10 12:56:28.815 INFO [0x1f7cd60c0] ClientConnection:193 | [ -> pulsar://pulsar-primary.acme.org:6651] Create ClientConnection, timeout=10000
2025-10-10 12:56:28.815 INFO [0x1f7cd60c0] ConnectionPool:124 | Created connection for pulsar://pulsar-primary.acme.org:6651-pulsar://pulsar-primary.acme.org:6651-0
2025-10-10 12:56:28.875 INFO [0x16cf07000] ClientConnection:410 | [192.168.100.214:65139 -> < redacted_ip >] Connected to broker
2025-10-10 12:56:38.836 ERROR [0x16cf07000] ClientConnection:634 | [192.168.100.214:65139 -> < redacted_ip >] Connection was not established in 10000 ms, close the socket
2025-10-10 12:56:38.837 INFO [0x16cf07000] ClientConnection:1336 | [192.168.100.214:65139 -> < redacted_ip >] Connection disconnected (refCnt: 2)
2025-10-10 12:56:38.837 INFO [0x16cf07000] ConnectionPool:141 | Remove connection for pulsar://pulsar-primary.acme.org:6651-pulsar://pulsar-primary.acme.org:6651-0
2025-10-10 12:56:38.837 INFO [0x16cf07000] RetryableOperation:114 | Reschedule get-partition-metadata-persistent:/< redacted_topic > for 100 ms, remaining time: 29900 ms
2025-10-10 12:56:38.837 INFO [0x16cf07000] ClientConnection:282 | [192.168.100.214:65139 -> < redacted_ip >] Destroyed connection to pulsar://pulsar-primary.acme.org:6651-0
```

After switching the client to use `pulsar+ssl://`, the example consumer code works with no other changes.
```python
client = pulsar.Client("pulsar+ssl://pulsar-primary.acme.org:6651")
```

Is this difference in behavior known and/or expected?

貢獻指南

開啟貢獻指南

研究方向

從 examples/consumer.py 以及 issue 中顯示的 pulsar.Client 連線選項開始。比較 use_tls=True 路徑與 pulsar+ssl:// URL 路徑,然後根據文件中已棄用的引數和回報的 Proxy 設定驗證行為;當兩種形式都處理相同的 TLS 連線情境,或已清楚記錄所支援的差異時,即表示完成。

由索引模型根據 Issue 內容生成。

評估

技術堆疊
python
領域
distributed-systems
Issue 類型
缺陷
難度
3/5
預估耗時
1-2 天
活躍度
停滯
描述清晰度
基本清楚
新手友好度
38/100

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。