pulsar
pulsar copied to clipboard
[Improve] Code simplify in AbstractBaseDispatcher in filterEntriesForConsumer loop
Search before asking
- [X] I searched in the issues and found nothing similar.
Motivation
-
batch
subscription.acknowledgeMesagein filterEntriesForConsumer loop -
remove unnecessary Optional package parameter for
filterEntriesForConsumermetadataArray -
avoid call O(consumer) times of
topic.getMigratedClusterUrlincheckAndApplyReachedEndOfTopicOrTopicMigration
Solution
No response
Alternatives
No response
Anything else?
No response
Are you willing to submit a PR?
- [X] I'm willing to submit a PR!