MySabers commented on issue #10399:
URL: https://github.com/apache/pulsar/issues/10399#issuecomment-827464193
Successfully connected to cluster.
```python
import pulsar
import time
client =
pulsar.Client('pulsar://10.255.174.52:6650,10.255.174.53:6650,10.255.174.54:6650')
producer = client.create_producer('ct')
```
However, when we tried to turn off one of the broker(10.255.174.52:6650),
the following exception occurred:
```python
2021-04-27 17:22:40.946 INFO [0x11006fe00] ConnectionPool:85 | Created
connection for pulsar://10.255.174.52:6650,10.255.174.53:6650,10.255.174.54:6650
2021-04-27 17:22:40.948 ERROR [0x70000d0c5000] ClientConnection:385 |
[<none> -> pulsar://10.255.174.52:6650,10.255.174.53:6650,10.255.174.54:6650]
Failed to establish connection: Connection refused
2021-04-27 17:22:40.948 INFO [0x70000d0c5000] ClientConnection:1372 |
[<none> -> pulsar://10.255.174.52:6650,10.255.174.53:6650,10.255.174.54:6650]
Connection closed
2021-04-27 17:22:40.948 ERROR [0x70000d0c5000] ClientImpl:181 | Error
Checking/Getting Partition Metadata while creating producer on
persistent://public/default/ct -- ConnectError
2021-04-27 17:22:40.948 INFO [0x70000d0c5000] ClientConnection:235 |
[<none> -> pulsar://10.255.174.52:6650,10.255.174.53:6650,10.255.174.54:6650]
Destroyed connection
Traceback (most recent call last):
File "/Users/hansi/PycharmProjects/test/pulsar_test.py", line 6, in
<module>
producer = client.create_producer('ct')
File "/usr/local/lib/python3.8/site-packages/pulsar/__init__.py", line
525, in create_producer
p._producer = self._client.create_producer(topic, conf)
Exception: Pulsar error: ConnectError
Process finished with exit code 1
```
is there anything we didn't notice?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
