pulsar-client-python

pulsar-client-python copied to clipboard

# Motivation Two of the three message chunking related settings in the ConsumerConfiguration have already been exposed to the consumer. Namely, maxPendingChunkedMessage and autoAckOldestChunkedMessageOnQueueFull. However, the third one, expireTimeOfIncompleteChunkedMessageMs, has...

hyperevo

[Bug] when pulsar python-client use tls connect pulsar then run coredump

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 2.10.2 ### Minimal reproduce step My os is eulerosv2r10.x86_64 ``` $ ./python Python...

liliang950210

https://github.com/apache/pulsar-client-python/actions/runs/5493895300/jobs/10012373710?pr=138 ``` ====================================================================== 2023-07-08 10:09:29.109 ERROR [139724761126464] ClientImpl:214 | Error Checking/Getting Partition Metadata while creating producer on persistent://public/default/oauth2-test-base64 -- AuthenticationError ERROR: test_base64 (__main__.Oauth2Test) 2023-07-08 10:09:29.110 INFO [139724795805696] ClientImpl:614 | Closing...

shibd

[Feature request] Enable AUTO_CONSUME

2

It doesn't seem like the python client supports auto consume. This does however seem to be the case for the java client as documented [here](https://pulsar.apache.org/docs/2.10.x/schema-understand/). It would be useful to...

kvedes

Client is highly fork-unsafe: any usage of multiprocessing deadlocks if an at-fork hook triggers garbage collection of a Pulsar client

10

## Context: - Pulsar 2.10.2 (StreamNative) - Pulsar client Python 2.10.1 and 3.1.0 both repro'd. - Python 3.10 and 3.7 - Linux (Ubuntu 20) and MacOS. ## Bug description: It's...

zbentley

exceptions must derive from BaseException

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 3.1.0 ### Minimal reproduce step def callback(self,res): self.logger.info(f"Message published,data={res}") producer = self.client.create_producer(topic, compression_type=pulsar.CompressionType.LZ4...

baigang666

[Bug] python pulsar client create producer thread suspend because of deadlock

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 2.10.2 pulcar-client-cpp ### Minimal reproduce step When the Python client is repeatedly invoked...

ZHr-UChiHa

PIP: https://github.com/apache/pulsar/pull/20453 ### Motivation Enable hostname verification by default. ### Modifications * Update the default value and the documentation to show the new default value. ### Verifying this change This...

michaeljmarshall

bad_weak_ptr will be thrown if client.close() is not called after ResultInterrupted is caught

1

Reproduce: ```python3 import pulsar client = pulsar.Client('pulsar://localhost:6650') consumer = client.subscribe('my-topic', "my-sub") while True: try: msg = consumer.receive() consumer.acknowledge(msg) except Exception as e: print("Exception: {}".format(type(e))) break ``` Press Ctrl+C and you...

BewareMyPower

[python client] message properties are not round-trippable

3

**Describe the bug** Properties objects on messages can be set to (and published with) values that cannot be deserialized on the far side. **To Reproduce** 1. Using the Python client,...

zbentley