lhotari commented on PR #15051: URL: https://github.com/apache/pulsar/pull/15051#issuecomment-1092496551
> It's just a guess at one of the possibilities for "Why #14970 problem happend". > > Because there has only one instance in `consumerSet`, so two consumer instance has same `address` & `consumerId`, so there are only two possibilities: > > * Consumer restart use same SocketAddress. > * One consumer instance execute command-subscribe more times in a short time. > > After code-review on the second possibility, finds possibility-case and fixed it. > > Maybe there are other problems that can reproduce #14970 problem I don't think that this PR fixes that issue. ServerCnx is tied to a single TCP/IP connection and even without the changes in this PR, duplicates on the same connection are prevented. As mentioned before, this PR is useful since it fixes a race condition and returns ServiceNotReady in the case that the future completes after the check has been made (as explained in https://github.com/apache/pulsar/pull/15051#issuecomment-1092431543). -- 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]
