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:
[email protected]


With regards,
Apache Git Services

Reply via email to