rkaw92 commented on issue #230: URL: https://github.com/apache/pulsar-client-node/issues/230#issuecomment-1240333920
I currently rely on back-off, but it's not optimal. As for filling the queue, I'd think that issuing exactly as many `send()` operations as should fit in the buffer (exactly equal to maxPendingMessages) and then flushing should get rid of them all, so that the new pending messages = 0. The code is running the latest master version from this repository. As for the C++ counterpart, it's 2.9.1 from a .deb. I'll try to debug the C++ library - clearly, there's something going on with flush unreliability. I'll also check if the behavior is the same between the normal Producer and the PartitionedProducer. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
