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.
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_fullis set or no, or whatmax_pending_messagesorbatching_max_messagesare.Slowing down a client helps (Introducing artifical pauses, or often flush())
Never seen that in a java client.