pulsar-client-python

pulsar-client-python copied to clipboard

Cannot seek on partitioned topic

3

As per https://github.com/apache/pulsar/issues/3643, it seems pulsar should support seeking on partitioned topics. This functionality seems partially missing in the C++ and python clients. # Reproduction First, run a pulsar standalone...

Samreay

Hey guys, I am on an IBM Power 8 & 9 server trying to install pulsar-client for python but there is no binary for ppc64le. If that could be packaged...

uwzis

publish sdist for pypi

5

👋 right now there is no sdist on pypi, can you publish the sdist there for easy downstream consumption? Thanks!

chenrui333

Use PyBind `py::gil_scoped_release` C++ class instead of the Python C Macros `Py_BEGIN_ALLOW_THREADS` for releasing / reacquiring the GIL. This is just a code readability refactor.

merlimat

Segmentation fault sometimes happens when running unit tests

2

See - https://github.com/apache/pulsar-client-python/actions/runs/8242753702/job/22542297702?pr=202 - https://github.com/apache/pulsar-client-python/actions/runs/8242753702/job/22542206316?pr=202 ``` ... 2024-03-12T02:35:31.1396530Z 2024-03-12 02:35:31.139 DEBUG [140455429797440] ClientConnection:886 | [[::1]:52958 -> [::1]:6650] Handling incoming command: SEND_RECEIPT 2024-03-12T02:35:31.1398821Z 2024-03-12 02:35:31.139 DEBUG [140455429797440] ClientConnection:1498 | [[::1]:52958 ->...

BewareMyPower

Avro EOF Error

1

Hello, I am having a bit of an issue running functions in Python with Avro. I am creating a message from Java that is serialized using a schema file without...

RainbowZephyr

max_total_receiver_queue_size_across_partitions does not work

10

**Describe the bug** The `max_total_receiver_queue_size_across_partitions` kwarg to the Python `subscribe` method is nonfunctional. **To Reproduce** 1. Create a persistent partitioned topic. I used 4 partitions. 2. Create a `Shared` subscription...

zbentley

Python3 AsyncIO implementation

13

**Copy from: https://github.com/apache/pulsar/issues/6308** Is your feature request related to a problem? Please describe. Implement python3 await/ async and using the event loop in order to save IO waiting time Describe...

houyingkun

The `pulsar.Result` enum is just imported from the C extension. See https://github.com/apache/pulsar-client-python/blob/daabc677e06e867f84beaeb3912d1d450cddf54d/pulsar/__init__.py#L50 Running `help(pulsar.Result)` could only show the underlying C error codes like ``` | | AlreadyClosed = | |...

BewareMyPower

python client does not retry when get topic partition metadata to create producer fails

5

**Describe the bug** If you fail to get topic partition metadata through service_url, it will not retry and try to connect to other ip, and will directly exit abnormally after...

yebai1105