Used:
python: 3.9.6
pulsar-client 3.0.0
Pulsar: docker on localhost of apachepulsar/pulsar:2.11.0
Just made a simple script that sendsAsync thousand messages (Strings) in a for loop.
And script at some point just hangs. No any errors in log or in a callbacks or anything.
Doesn't matter if flag block_if_queue_full
is set or no, or what max_pending_messages
or batching_max_messages
are.
Slowing down a client helps (Introducing artifical pauses, or often flush())
Never seen that in a java client.