zbentley commented on issue #15705: URL: https://github.com/apache/pulsar/issues/15705#issuecomment-1134700810
@codelipenghui thank you for the explanation; that makes sense. Two clarifications: 1. How does this apply to nacked messages? if a new KeyShared consumer `c2` is blocked due to markDeletePosition not being caught up to the point where `c2` joined, if an existing consumer `c1` negatively acknowledges a message that hashes to `c2`, will the nacked message go to `c2` or `c1`? 1. Address this limitation, do you really need to track state for every key in the topic? I may be naïve here, but it seems to me that you would only need to track state for **each key which has messages that have been dispatched to a consumer**. That's still an O(N) state where there's currently not one, but it's a much smaller N. This might be getting into feature request territory now though. -- 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]
