[GitHub] [pulsar] easyfan opened a new issue #4569: C++ client producer sendAsync() method will be blocked forever, if enough batched messages sent timeout.

[GitBox <gi...@apache.org>]

easyfan opened a new issue #4569: C++ client producer sendAsync() method will be blocked forever, if enough batched messages sent timeout.
URL: https://github.com/apache/pulsar/issues/4569
 
 
   **Describe the bug**
   C++ client producer sendAsync() method will be blocked forever, if enough batched messages sent timeout.
   **To Reproduce**
   
   1. Using the following producer configures: 
   setBatchingEnabled(true)
   setBlockIfQueueFull(true)
   setSendTimeout(100) (shorter timeout interval would help reproduce the issue)
   2. Producing huge plant of messages (better in a pressure test env.);
   3. Try to made some producer timeout happens (with shorter timeout interval for example)
   4. After accumulating enough timeout captured, the pulsar::Producer::sendAsync method will be blocked and will nerver turned back to available.
   
   **Expected behavior**
   The method pulsar::Producer::sendAsync(...) might be blocked for a while, if the pending messages reached the max value, but it shall be returned back available if previous pending messages acked or reaching timeout point.
   
   
   **Desktop (please complete the following information):**
    - OS: Centos 
   
   

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services