lhotari commented on pull request #5278: URL: https://github.com/apache/pulsar/pull/5278#issuecomment-691994440
> PR #7141 is merged. You can try out on the master branch. I will move this PR to 2.7.0 first since we need to prepare the 2.6.0 release. @codelipenghui PR #7141 doesn't seem to help with Pulsar Readers since Readers are always using exclusive subscriptions under the covers (https://github.com/apache/pulsar/blob/208af7cd7e718d378707df4aba600be3202e23df/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java#L48). Since a Pulsar Reader wraps a Consumer internally, I was thinking of the possibility of using a NonDurable Consumer directly without the Reader "wrapper". However this approach fails because creating NonDurable Consumers remains broken, that I have reported as #7436. @codelipenghui would it be possible to extend the solution that was made in #7141 to also cover Readers? I'm having issues with using seekAsync + hasMessageAvailableAsync on Readers. It seems that there are race conditions because of the current solution that disconnects from the broker side after the seek. The usage of seek + hasMessageAvailableAsync in Readers isn't deterministic at all. There's a separate issue about the issues with hasMessageAvailabe after seek, that's #7796 . ---------------------------------------------------------------- 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]
