lhotari commented on PR #24100:
URL: https://github.com/apache/pulsar/pull/24100#issuecomment-2740295603

   > You can run `testInterruptedWhenCreateConsumer ` to reproduce it.
   
   @shibd That's not reproducing this flow what you described in the PR 
description
   
   > For example:
   > 
   > * Thread A - call subscribe() method
   > * Thread A - blocking on waiting for the response of the consumer creation
   > * The user framework interrupted `Thread A` for aborting a job.
   > * Cannot close the consumer since user will get InterruptedException and 
can't get consumer object
   
   The step "Cannot close the consumer since user will get InterruptedException 
and can't get consumer object" is missing. Adding a separate test case that 
reproduces the user's flow would be useful as I have explained before. Just 
simply put it in code in a test case which clarifies what "Cannot close the 
consumer since user will get InterruptedException and can't get consumer 
object" means. That's the most simplest way without wasting time in writing 
comments. :) 


-- 
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