Yunze Xu
Yunze Xu
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 = | |...
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...
Similar to https://github.com/apache/pulsar-client-cpp/issues/4
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar-client-cpp/issues) and found nothing similar. ### Version 3.5.0 ### Minimal reproduce step See https://github.com/apache/pulsar/pull/22306 ### What did you expect to...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar-client-cpp/issues) and found nothing similar. ### Version master ### Minimal reproduce step https://github.com/apache/pulsar-client-cpp/actions/runs/8229708235/job/22501936954?pr=409 ### What did you expect to see?...
### Motivation Currently the main branch is broken by the concurrent merge of https://github.com/apache/pulsar-client-cpp/pull/153 and https://github.com/apache/pulsar-client-cpp/pull/151. It's because when a batched message id is constructed from deserialization, there is no...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar-client-cpp/issues) and found nothing similar. ### Version main ### Minimal reproduce step Enable `ackReceipt` for https://github.com/apache/pulsar-client-cpp/blob/main/tests/extensibleLM/ExtensibleLoadManagerTest.cc ```c++ ConsumerConfiguration consumerConf; consumerConf.setAckReceiptEnabled(true);...
TODO: libpulsarwithdeps.a is not built
```c++ #include #include #include #include "lib/LogUtils.h" DECLARE_LOG_OBJECT() using namespace pulsar; int main(int argc, char *argv[]) { ClientConfiguration conf; conf.setIOThreads(8); Client client{"pulsar://localhost:6650", conf}; for (int i = 0; i < 5;...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar-client-cpp/issues) and found nothing similar. ### Version - Pulsar: 3.1.0 - Client: main (https://github.com/apache/pulsar-client-cpp/commit/bb16f24bb68699c15eddba3163cfbef0b1282ebf) ### Minimal reproduce step Run the...