pulsar-client-python

pulsar-client-python copied to clipboard

### Motivation CPP client supported `KeyValue` schema on https://github.com/apache/pulsar-client-cpp/pull/22. Python clients also can support KeyValue schemas based on this. ### Alternatives Note: The schema function of the Python client is...

shibd

Pulsar Identity SerDe behaviour and documentation

5

If you look at http://pulsar.apache.org/docs/en/functions-develop/#serde under the Python tab it says "In Python, the default SerDe is identity, meaning that the type is serialized as whatever type the producer function...

baynes

many "Connection closed" messages after receiving the warning "Received send error from the server: Cannot determine whether the message is a duplicate at this time" from producer

5

In my program, there will be eight producers, two of which will be sent to partitioned topics and six of which will be sent to unpartitioned topics. Below is my...

TalkWIthKeyboard

Consider the following Python code: ``` print("----------> 1") auth_token = "" print("----------> 2") pulsar_client = pulsar.Client("pulsar+ssl://dev-stream-int.datamanaged.io:6651", authentication=pulsar.AuthenticationToken(auth_token)) print("----------> 3") producer = pulsar_client.create_producer('persistent://bladerunner/notification/subscribe') print("----------> 4") producer.send("Hammurabi".encode('utf-8'), None) print("----------> 5") ``` When...

jesumyip

[Bug] Python pulsar-client producer does not produce messages with gunicorn `--preload` flag

3

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Pulsar brokers version 2.9 python 3.9 Tested on macOS and in production (Linux)...

whisust

Whether the Python client has the "listenerName" options

1

JAVA SDK provide a `listenerName` [options](https://pulsar.apache.org/blog/2020/06/18/Apache-Pulsar-2-6-0/?ref=https://githubhelp.com#pip-61-advertise-multiple-addresses) in version 2.6 And I wonder is there a similar options in the Python client.

peiyangL

Use Protobuf as schema registry for python client

3

**Is your enhancement request related to a problem? Please describe.** I was wondering if there was a possibility to use protobuf in order to auto-generate code for my pulsar client...

zhavir

[python-client] Support KeySharedPolicy in consumer configuration

2

Support for auto-hash and sticky-hash based policy (https://github.com/apache/pulsar/issues/4077) was added to cpp client (https://github.com/apache/pulsar/pull/7842) java (https://github.com/apache/pulsar/pull/5928) & go (https://github.com/apache/pulsar-client-go/pull/363) It would be great to have these changes ported to python...

amadav

The ArgumentError of the 'replication_clusters' in producer.send method in python pulsar.

3

I want to use the geo-replication in python pulsar and my code is below. ``` client = pulsar.Client("pulsar://localhost:6650") producer = client.create_producer("python_topic_00", schema=StringSchema()) producer.send("Message0", replication_clusters=["cluster1", "cluster2"]) ``` The error message is...

xuehuanran

On partitioned topics with the Python client, receiver_queue_size=0 results in an InvalidConfiguration error, but is documented to work

16

**Describe the bug** Passing `receiver_queue_size=0` to the Python client's `subscribe` method results in a `InvalidConfiguration` exception. However, [these docs](https://pulsar.apache.org/docs/cookbooks-message-queue/) indicate that a receiver queue size of 0 is supported. **To...

zbentley