lhotari commented on issue #23200: URL: https://github.com/apache/pulsar/issues/23200#issuecomment-2297322809
One observation is that this random delay in processing amplifies the problem: https://github.com/lhotari/pulsar-playground/blob/092584a01cfe70f086cdd4b7b8c7aeb6cf3a54c6/src/main/java/com/github/lhotari/pulsar/playground/TestScenarioIssueKeyShared.java#L308-L315 I haven't yet verified it, but it seems that the problem is reduced when a `messageListener` is used for processing the messages. One possible explanation is that there's yet another queue in the client side when a `messageListener` is used, it's the executor's queue. I'll have to continue experiments to understand why. -- 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]
