This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 6505da103aa [improve][ml] Offload ledgers without check ledger length
(#24344)
new 4a845041ebf Fix checkstyle after previous cherry-picks
new 4927eff4d50 [fix][io] Fix kinesis avro bytes handling (#24316)
new 06ead669792 [fix][test] Fix flaky
AutoScaledReceiverQueueSizeTest.testNegativeClientMemory (#24324)
new 28dc3a16b2f [fix][offload] Complete the future outside of the reading
loop in BlobStoreBackedReadHandleImplV2.readAsync (#24331)
new 448d5d09522 [fix][ml] Fix ManagedCursorImpl.individualDeletedMessages
concurrent issue (#24338)
new 3a2d674e0b3 [fix][broker] Resolve the issue of frequent updates in
message expiration deletion rate (#24190)
new e3b64a2242e [fix][broker] Ignore metadata changes when broker is not
in the Started state (#24352)
new f03d8d9a79a [fix][io] Acknowledge RabbitMQ message after processing
the message successfully (#24354)
new 7eb708940ed [improve][broker]Improve the log when encountered
in-flight read limitation (#24359)
new a8586832f93 [fix][broker] expose consumer name for partitioned topic
stats (#24360)
new 051c676dc0d [improve][offloaders] Automatically evict Offloaded
Ledgers from memory (#19783)
The 11 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:
conf/broker.conf | 4 +
.../bookkeeper/mledger/ManagedLedgerConfig.java | 9 ++
.../bookkeeper/mledger/OffloadedLedgerHandle.java | 10 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 6 ++
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 74 ++++++++++++++-
.../mledger/impl/cache/InflightReadsLimiter.java | 23 +++--
.../mledger/impl/cache/RangeEntryCacheImpl.java | 5 +-
.../impl/OffloadEvictUnusedLedgersTest.java | 104 +++++++++++++++++++++
.../mledger/impl/OffloadPrefixReadTest.java | 20 +++-
.../apache/pulsar/broker/ServiceConfiguration.java | 8 ++
.../pulsar/broker/service/BrokerService.java | 18 +++-
.../broker/service/TopicPoliciesService.java | 4 +-
.../persistent/PersistentMessageExpiryMonitor.java | 3 +-
.../service/persistent/PersistentReplicator.java | 1 +
.../broker/service/persistent/PersistentTopic.java | 1 +
.../apache/pulsar/broker/admin/AdminApi2Test.java | 23 +++++
.../pulsar/broker/stats/PrometheusMetricsTest.java | 4 +
.../impl/AutoScaledReceiverQueueSizeTest.java | 8 +-
.../policies/data/stats/ConsumerStatsImpl.java | 1 +
.../pulsar/io/kinesis/json/JsonConverter.java | 7 +-
.../org/apache/pulsar/io/kinesis/UtilsTest.java | 33 ++++---
.../pulsar/io/kinesis/json/JsonConverterTests.java | 3 +-
.../apache/pulsar/io/rabbitmq/RabbitMQSource.java | 31 +++++-
.../integration/io/sinks/KinesisSinkTester.java | 12 ++-
.../jcloud/impl/BlobStoreBackedReadHandleImpl.java | 17 +++-
.../impl/BlobStoreBackedReadHandleImplV2.java | 2 +-
26 files changed, 371 insertions(+), 60 deletions(-)
copy
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Sink.java
=>
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/OffloadedLedgerHandle.java
(78%)
create mode 100644
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/OffloadEvictUnusedLedgersTest.java
