pulsar-client-python

pulsar-client-python copied to clipboard

When reading a compacted topic with `is_read_compacted=True` `has_message_available` returns true even after all messages have been read when there is a tombstone message. This might be related to #199. As...

telnoratti

The producer performance of pulsar-client v3.5.0 is much lower than that of v2.10.2

3

When using pulsar-client v3.5.0 and pulsar-client v2.10.2 to send the same batch of data (about 100MB), 3.5.0 takes about 3.5 times longer than 2.10.2. ### Core Code ```shell async def...

Jayer23

auth_config = { 'saslJaasClientSectionName': 'PulsarClient', 'serverType': 'broker', 'kerberosServiceName': 'pulsar', 'useKeyTab': 'true', 'keyTab': 'D:\\user.keytab', 'principal': 'test' } client = pulsar.Client('pulsar://127.0.0.1:6650',authentication=pulsar.Authentication( 'org.apache.pulsar.client.impl.auth.AuthenticationSasl', str(auth_config) )) and i get lib\Authentication:190 | Couldn't load auth...

studyandstudy

## Motivation Add support for Python 3.14 to keep the client up-to-date with the latest Python releases. ## Modifications - Upgraded pybind11 from 2.10.1 to 3.0.1 for Python 3.14 compatibility...

matthewmarion

BewareMyPower

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

1

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...

mattsre

has_message_available() with timestamp seek returns True on first call when reaching end of the topic

3

Ran into this while trying to upgrade to the v3.8.0 Python client. Tested on a Pulsar v4.0.4 cluster, which is after [this issue](https://github.com/apache/pulsar/pull/23502) was fixed in Pulsar v4.0.1. Possibly related...

abeliangroupie

### Motivation Support E2EE ECDSA algorithm.

gaoran10

### 📝 Feature Request: Expose `create_producer` Parameters in `pulsar.asyncio.Client` #### Summary I'd like to request enhanced support for configuring producers in the `pulsar.asyncio.Client` by exposing the same parameters available in...

justinreddick

``` 2025-05-27 10:04:07.122 INFO [0x16cf1f000] HTTPLookupService:223 | Curl Lookup Request sent for http://11.22.22.11:80/admin/v2/persistent/test/basicTests/testProduce/partitions?checkAllowAutoCreation=true 2025-05-27 10:04:08.574 INFO [0x16cf1f000] HTTPLookupService:239 | Response received for url http://11.22.22.11:80/admin/v2/persistent/test/basicTests/testProduce/partitions?checkAllowAutoCreation=true responseCode 200 2025-05-27 10:04:08.574 INFO [0x16cf1f000]...

programmerahul