search

apache / pulsar-client-python

Apache Pulsar Python client library
https://pulsar.apache.org/
Apache License 2.0
51 stars 40 forks source link

Producer.sendAsync hangs if rate is high enough #94

Closed BoillMan133 closed 1 year ago

BoillMan133 commented 1 year ago

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.

hyperevo commented 1 year ago

Pretty sure this is fixed in 3.0.1. https://github.com/apache/pulsar-client-python/pull/87

BoillMan133 commented 1 year ago

Pretty sure this is fixed in 3.0.1. #87

Thanks for an update. Do you know when 3.0.1 planned to be released ?

BewareMyPower commented 1 year ago

@BoillMan133 The 3.1.0 candidate 4 is voting currently, if there is nothing wrong we can have it in PyPI next week: https://lists.apache.org/thread/lyzyyg9yhwc836trv0dhdgq23bym4som

merlimat commented 1 year ago

Release 3.1.0 is available