This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 6a2e6fc [Issue #11348][pulsar-broker] Fix can not get leader broker
in follower brokers (#11353)
add 497e911 Support broker level dispatch rate limiter (#11325)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 8 +
.../apache/pulsar/broker/ServiceConfiguration.java | 14 ++
.../broker/service/AbstractBaseDispatcher.java | 21 +++
.../pulsar/broker/service/BrokerService.java | 18 +-
.../org/apache/pulsar/broker/service/Topic.java | 4 +
.../NonPersistentDispatcherMultipleConsumers.java | 5 +
...onPersistentDispatcherSingleActiveConsumer.java | 5 +
.../service/persistent/DispatchRateLimiter.java | 33 +++-
.../PersistentDispatcherMultipleConsumers.java | 70 ++++---
.../PersistentDispatcherSingleActiveConsumer.java | 101 ++++++-----
...istentStickyKeyDispatcherMultipleConsumers.java | 3 +
.../broker/service/persistent/PersistentTopic.java | 5 +
.../SubscriptionMessageDispatchThrottlingTest.java | 202 +++++++++++++++++++++
13 files changed, 410 insertions(+), 79 deletions(-)
