This is an automated email from the ASF dual-hosted git repository.
zhaocong pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from c8d2bba651b [improve][broker] PIP-192 Fix getLastMessageId for
compressed payload(And add compression and maxBatchSize for the load balance
system topic) (#20087)
new 0a3a02bb4ed [fix][broker] Fix avoid future of clear delayed message
can't complete (#20075)
new d05871213ad [fix][broker] Ensure previous delayed index be removed
from snapshotSegmentLastIndexTable & Make load operate asynchronous (#20086)
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../BucketDelayedDeliveryTrackerFactory.java | 28 ++++++
.../pulsar/broker/delayed/bucket/Bucket.java | 3 +-
.../bucket/BucketDelayedDeliveryTracker.java | 110 ++++++++++++---------
.../PersistentDispatcherMultipleConsumers.java | 30 ++----
.../broker/service/persistent/PersistentTopic.java | 26 ++---
.../bucket/BucketDelayedDeliveryTrackerTest.java | 30 ++++--
.../persistent/BucketDelayedDeliveryTest.java | 48 +++++++++
7 files changed, 187 insertions(+), 88 deletions(-)
