Zac Bentley
Zac Bentley
A few questions to get debugging information: What is your launchd `.plist` file, or how did you install the script into launchd? Where is the Mechanize module? In the terminal,...
I'd love a fix for this as well, as its unintuitive behavior confused me for a while today. Specifically, `rye` should emit an error or a warning when: - `rye...
@codelipenghui this issue occurs with and without `batching_enabled` in the producer. Additionally, with `batching_enabled=True` it occurs regardless of which batching strategy is used.
I edited the code in the example to print out ledger/entry/partition/batch so that it is evident that the batch index is `-1` for messages received.
@codelipenghui no, see example code: > `consumer_name=f'testconsumer-{os.getpid()}'`
> a fully-native Python client is only more friendly for Python developers, not Python users. I disagree. A lot of issues with python binary extensions in general boil down to...
@BewareMyPower perhaps, though issues related to 2 and 3 largely occurred for me while trying to use Pulsar from ordinary python code, rather than trying to develop features on the...
This package already provides asynchronicity (`Producer.send_async` and the `message_listener` argument to the client). While those don't provide `async` or `await` _syntactic constructs_, they are _asynchronous_ (nonblocking) and can be integrated...
[backtrace.txt](https://github.com/apache/pulsar-client-python/files/11626067/backtrace.txt) Thanks @BewareMyPower. Here are the logs from a run (MacOS 11, Python 3.10.9, client 3.1.0) that got stuck with 4 processes, connecting explicitly to the topic `persistent://chariot1/chariot_ns_sre--kms_test/chariot_topic_kms_test-partition-1`: ``` Joining...