lhotari edited a comment 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/aff700ccd0a7f0264cb3de027ac44eab6a65a258 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]
