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 227f947f148 [improve][offloaders] Automatically evict Offloaded
Ledgers from memory (#19783)
new 92a19301a16 [fix][broker]Fix deadlock when compaction and topic
deletion execute concurrently (#24366)
new 639521ba516 [improve][ml]Release idle offloaded read handle only the
ref count is 0 (#24381)
new 7ed6edc8edd [improve][broker] Added synchronized for sendMessages in
Non-Persistent message dispatchers (#24386)
new b07a403f0d6 [fix][client] Fix consumer not returning encrypted
messages on decryption failure with compression enabled (#24356)
new dfcc246546a [improve][broker] Make maxBatchDeletedIndexToPersist
configurable and document other related configs (#24392)
new b55a3f7171d [improve][broker] Add
managedCursor/LedgerInfoCompressionType settings to broker.conf (#24391)
new 8ae31999026 [improve][misc] Upgrade Netty to 4.1.122.Final and
tcnative to 2.0.72.Final (#24397)
new 9adbbbf8f39 [fix][ml]Revert a behavior change of releasing idle
offloaded ledger handle: only release idle BlobStoreBackedReadHandle (#24384)
The 8 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:
buildtools/pom.xml | 2 +-
conf/broker.conf | 57 ++++++++--
conf/standalone.conf | 43 ++++++-
distribution/server/src/assemble/LICENSE.bin.txt | 54 ++++-----
distribution/shell/src/assemble/LICENSE.bin.txt | 52 ++++-----
.../bookkeeper/mledger/ManagedLedgerConfig.java | 10 ++
.../bookkeeper/mledger/OffloadedLedgerHandle.java | 4 +
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 13 ++-
pom.xml | 2 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 24 +++-
.../pulsar/broker/service/AbstractTopic.java | 3 +
.../pulsar/broker/service/BrokerService.java | 2 +
...onPersistentDispatcherSingleActiveConsumer.java | 2 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 2 +-
.../broker/service/persistent/PersistentTopic.java | 1 +
.../org/apache/pulsar/client/api/RawReader.java | 11 +-
.../apache/pulsar/client/impl/RawReaderImpl.java | 23 +++-
.../org/apache/pulsar/compaction/Compactor.java | 2 +-
.../client/api/SimpleProducerConsumerTest.java | 89 +++++++++++++++
.../pulsar/client/impl/ConsumerCloseTest.java | 42 ++++++-
.../apache/pulsar/client/impl/RawReaderTest.java | 66 ++++++++++-
.../apache/pulsar/compaction/CompactionTest.java | 67 +++++++++++
.../pulsar/client/api/PulsarClientException.java | 11 ++
.../org/apache/pulsar/client/impl/ClientCnx.java | 2 +-
.../pulsar/client/impl/ConnectionHandler.java | 22 +++-
.../apache/pulsar/client/impl/ConsumerImpl.java | 126 ++++++++++++++++-----
.../apache/pulsar/client/impl/ProducerImpl.java | 39 +++++--
.../pulsar/client/impl/TopicListWatcher.java | 4 +-
.../client/impl/TransactionMetaStoreHandler.java | 4 +-
.../jcloud/impl/BlobStoreBackedReadHandleImpl.java | 24 +++-
30 files changed, 662 insertions(+), 141 deletions(-)
