lhotari commented on issue #8138: URL: https://github.com/apache/pulsar/issues/8138#issuecomment-700495311
The repro case using plain Pulsar Java Client is in this commit: https://github.com/lhotari/pulsar/commit/3314b3bb4f1e00f9d6c670efd9448d32c20e7a6f It programmatically triggers a heap dump that gets written in the temp directory. I ran it against Pulsar 2.6.1 standalone server running in Docker. The heap dump shows that in the client, there's no unclosed consumers or producers at the end of the test before the client is closed. However in my case, there are 923 strong references to ConsumerImpl instances from ClientCnx.consumers. All ConsumersImpl instances seem to be in Closed state so it's not that closing would have been skipped. It seems like a race condition that happens because of the behavior of the seek operation (see the previous comment for more details). ---------------------------------------------------------------- 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]
