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 a7e40ea [Issue 10896] add get message id by timestamp (#11139)
add ce6be12 [Broker] Fix broker dispatch byte rate limiter. (#11135)
No new revisions were added by this update.
Summary of changes:
.../broker/service/AbstractBaseDispatcher.java | 19 +++++++-
.../AbstractDispatcherMultipleConsumers.java | 5 ++-
.../AbstractDispatcherSingleActiveConsumer.java | 6 ++-
.../NonPersistentDispatcherMultipleConsumers.java | 5 +--
...onPersistentDispatcherSingleActiveConsumer.java | 6 +--
.../service/persistent/DispatchRateLimiter.java | 9 ++++
.../PersistentDispatcherMultipleConsumers.java | 50 ++++++++++++----------
.../PersistentDispatcherSingleActiveConsumer.java | 49 ++++++++++++---------
...istentStreamingDispatcherMultipleConsumers.java | 10 +++--
...entStreamingDispatcherSingleActiveConsumer.java | 11 +++--
.../streamingdispatch/StreamingEntryReader.java | 4 +-
.../client/api/MessageDispatchThrottlingTest.java | 42 +++++++-----------
12 files changed, 122 insertions(+), 94 deletions(-)
