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 7c8dc32 Fix NPE on opening non-durable cursors on an empty managed
ledger (#7133)
add c64b22a Introduce precise topic publish rate limiting (#7078)
No new revisions were added by this update.
Summary of changes:
.../apache/pulsar/broker/ServiceConfiguration.java | 6 +-
.../pulsar/broker/service/AbstractTopic.java | 43 +++++-
.../pulsar/broker/service/BrokerService.java | 10 +-
.../pulsar/broker/service/PublishRateLimiter.java | 92 +++++++++++++
.../apache/pulsar/broker/service/ServerCnx.java | 21 ++-
.../org/apache/pulsar/broker/service/Topic.java | 8 ++
.../PrecisTopicPublishRateThrottleTest.java | 153 +++++++++++++++++++++
.../broker/service/PublishRateLimiterTest.java | 112 +++++++++++++++
.../util/{BCLoader.java => RateLimitFunction.java} | 10 +-
.../org/apache/pulsar/common/util/RateLimiter.java | 11 ++
.../apache/pulsar/common/util/RateLimiterTest.java | 16 +++
11 files changed, 466 insertions(+), 16 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java
copy pulsar-common/src/main/java/org/apache/pulsar/common/util/{BCLoader.java
=> RateLimitFunction.java} (84%)
