pulsar-client-python
pulsar-client-python copied to clipboard
apache
Apache Pulsar Python client library
### Version OS: Ubuntu 22.04 Python: 3.10.2 Pulsar: pulsar-client==3.2.0 ### Minimal reproduce step ```python3 from pulsar.schema import JsonSchema, Record, Array, String class A(Record): a = String() class B(Record): b =...
This took me a little while to track down but im pretty sure its an actual bug. This seems simple enough to fix and I'd be willing to take on...
**Versions** Pulsar version 2.10.4 OS: Ubuntu(version=22.04) Client(Python): pulsar-client(Version=3.3.0) **Minimal reproduce step** Create a partitioned topic with one partition bin/pulsar-admin topics create-partitioned-topic persistent://public/default/test-consumer -p 1 Publish some messages Create one consumer...
Hello, When the pulsar server go down after a succressful connection to the python client, is there a way to check if that the connection is destroyed. like for instance...
I'm rather new to this project but, I thought it might be worthwhile to gauge the community's thoughts on implementing a fully-native Python client. Those of you who have a...
## Descripition The connection between client and server may be broken in some cases, for example, network fluctuations, so I was trying to have a retry logic when producer send...
We are using Python Pulsar producer clients in a web app that runs in UWSGI. We have our settings set to terminate and relaunch workers after a certain number of...
python: 3.6 pulsar-client: pulsar-client[avro]==2.10.2 celery: 5.1.2 code example: ```python #!/usr/bin/env python import time import random import string from pulsar import Client, CompressionType from pulsar.schema import AvroSchema, Record, String, Integer def...
The python implementation of PIP-165:https://github.com/apache/pulsar/issues/15516 Modifications Add new configuration ConnectionMaxIdleTime to ClientOptions Add a python routine to ConnectionPool to period check and release idle connections.
**Is your feature request related to a problem? Please describe.** This isn't necessarily a problem, but requires a workaround **Describe the solution you'd like** Simply add client = pulsar.Client(ip, stdout=False)...
