Samreay opened a new issue, #213: URL: https://github.com/apache/pulsar-client-python/issues/213
As per https://github.com/apache/pulsar/issues/3643, it seems pulsar should support seeking on partitioned topics. This functionality seems missing in the C++ and python clients. # Reproduction First, run a pulsar standalone instance: ```bash docker run -it -p 6650:6650 -p 8080:8080 --tmpfs /pulsar/data apachepulsar/pulsar:3.1.0 bin/pulsar standalone ``` Ensure you have pulsar client and httpx dependencies, and then run the following code: ```python import httpx import pulsar # Make the topic above with a single partition r = httpx.put("http://localhost:8080/admin/v2/persistent/public/default/example/partitions";, json=1) r.raise_for_status() client = pulsar.Client("pulsar://localhost:6650") consumer = client.subscribe("persistent://public/default/example", "sub") # Seek to the latest message, raises OperationNotSupported consumer.seek(pulsar.MessageId.latest) ``` # Expected Behaviour Seeking should work across partitions. A seek to latest should take you to latest across partitions. Seeking by a MessageId (which contains a partition number) should seek that partition. A seek to a timestamp should seek across all partitions. # Workarounds Is there any way in the provided python API to seek on a per-partition basis as a workaround? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
