merlimat opened a new pull request #11843:
URL: https://github.com/apache/pulsar/pull/11843


   
   ### Motivation
   
   In `MultiTopicsConsumer` we're doing a `receiveAsync()` operation to 
transfer messages from the individual consumers into the shared queue, but 
we're not handling the failure path of the returned `CompletableFuture`. 
   
   This future should in theory never fail, but it fail if there is some bug in 
the code, as it was the case for #11824. 
   
   The main issue is that since we're not handle the future failure path, the 
exception stack traces are completely hidden, making debugging such issues more 
complicated.
   
   ### Modification
   
    1. Print exception
    2. Retry later, to give it a chance to unblock itself


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

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to