btlqql opened a new pull request, #10919: URL: https://github.com/apache/rocketmq/pull/10919
## What is the purpose of the change Fix #10894. LiteSubscriptionRegistryImpl.addPartialSubscription checked only the current active count before processing, so a request adding multiple active Lite subscriptions could exceed maxLiteSubscriptionCount. addCompleteSubscription did not check the limit at all. At the same time an idempotent retry for an already active subscription was rejected once the quota was full. ## Brief changelog - LiteSubscriptionRegistryImpl.addPartialSubscription: check the quota per newly added lmqName, skipping entries the client already subscribes to - LiteSubscriptionRegistryImpl.addCompleteSubscription: apply the same per-entry quota check - added isLiteTopicSubscribed() helper that returns whether a client group is already registered for an lmqName, so idempotent retries are not rejected ## How was this patch verified - Code review of the quota arithmetic around addTopicGroup/removeTopicGroup - `git diff --check` clean -- 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]
