MarvinCai edited a comment on issue #10173: URL: https://github.com/apache/pulsar/issues/10173#issuecomment-817875498
So the future returned by `consumer.receiveAsync()` could be completed by the `pulsar-external-listener`'s thread, causing the following `thenAccept` also executed on `pulsar-external-listener`'s thread, this will happen if `incomingMessages` queue is empty when `consumer.receiveAsync()` is called. I think to fix this issue we can use thenAcceptAsync and provide a target executor for it. Could use a second opinion on this. -- 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]
