This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from cf10ac95c52 [clean][client] Clean code for the construction of
retry/dead letter topic name (#24082)
new 94a0147ad30 [fix][ci] Bump dependency-check to 12.1.0 to fix OWASP
Dependency Check job (#24083)
new 17f85e33b1e [fix][broker] Avoid IllegalStateException when marker_type
field is not set in publishing (#24087)
new 2fb9cb574f4 [fix][broker] Restore the behavior to dispatch batch
messages according to consumer permits (#24092)
new f3368b4b498 [improve][broker] Optimize message expiration rate
repeated update issues (#24073)
new 098d040ff6d [fix][ml] Fix issues in estimateEntryCountBySize (#24089)
The 5 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:
.../mledger/impl/EntryCountEstimator.java | 169 ++++++++++++++
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 51 +---
.../mledger/impl/cache/RangeEntryCacheImpl.java | 2 +-
.../mledger/impl/EntryCountEstimatorTest.java | 260 +++++++++++++++++++++
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 56 +++--
.../mledger/impl/ReadOnlyCursorTest.java | 39 +++-
pom.xml | 2 +-
.../service/persistent/MessageDeduplication.java | 2 +-
.../PersistentDispatcherMultipleConsumers.java | 6 +-
.../persistent/PersistentMessageExpiryMonitor.java | 4 +-
.../service/persistent/PersistentReplicator.java | 1 -
.../broker/service/persistent/PersistentTopic.java | 1 -
.../pulsar/broker/service/BatchMessageTest.java | 4 +
13 files changed, 515 insertions(+), 82 deletions(-)
create mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCountEstimator.java
create mode 100644
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/EntryCountEstimatorTest.java
