This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from a57f0390f20 [improve][broker] Don't log an error when
updatePartitionedTopic is called on a non-partitioned topic (#24943)
new 9a1c29652ad [fix][broker] fix getMaxReadPosition in
TransactionBufferDisable should return latest (#24898)
new d1d97b7235d [fix][broker] Use `poll` instead `remove` to avoid
`NoSuchElementException` (#24933)
new 2dc4eecac77 [fix][broker] ExtensibleLoadManager: handle
SessionReestablished and Reconnected events to re-register broker metadata
(#24932)
new fcb6a90b134 [fix][broker] Fix stack overflow caused by race condition
when closing a connection (#24934)
new 02a3bc3336d [fix][sec] Override kafka-clients in kinesis-kpl-shaded to
remediate CVE-2024-31141 and CVE-2025-27817 (#24935)
new c6978260e12 [fix][sec] Override commons-beanutils and
commons-configuration2 to remediate CVEs (#24936)
new df468d13268 [fix][test] Stabilize testMsgDropStat by reliably
triggering non-persistent publisher drop (#24929)
new a5fd55f3a03 [fix][broker] Fix bug in PersistentMessageExpiryMonitor
which blocked further expirations (#24941)
new c30cb6a77ad [fix][sec] Override nimbus-jose-jwt to remediate
CVE-2023-52428 and CVE-2025-53864 (#24937)
new 3717b795e9b [fix][admin] Set local policies overwrites "number of
bundles" passed during namespace creation (#24762)
new e626c0232ad [feat][client] PIP-234: Support shared resources in
PulsarAdmin to reduce thread usage (#24893)
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:
pom.xml | 19 +++
.../pulsar/broker/admin/impl/NamespacesBase.java | 34 +++--
.../loadbalance/extensions/BrokerRegistryImpl.java | 14 ++
.../AbstractDispatcherSingleActiveConsumer.java | 29 +++-
.../persistent/PersistentMessageExpiryMonitor.java | 1 +
.../broker/service/persistent/PersistentTopic.java | 8 +-
.../buffer/impl/TransactionBufferDisable.java | 3 +-
.../apache/pulsar/client/impl/RawReaderImpl.java | 5 +-
.../PersistentMessageExpiryMonitorMockTest.java | 129 ++++++++++++++++++
.../pulsar/broker/admin/NamespacesV2Test.java | 149 +++++++++++++++++++++
.../pulsar/broker/service/ZkSessionExpireTest.java | 4 +-
...rsistentDispatcherSingleActiveConsumerTest.java | 81 +++++++++++
.../pulsar/client/api/NonPersistentTopicTest.java | 85 +++++++-----
.../pulsar/client/admin/PulsarAdminBuilder.java | 14 ++
.../admin/internal/PulsarAdminBuilderImpl.java | 12 +-
.../client/admin/internal/PulsarAdminImpl.java | 10 +-
.../admin/internal/http/AsyncHttpConnector.java | 104 ++++++++++++--
.../internal/http/AsyncHttpConnectorProvider.java | 5 +-
.../admin/internal/PulsarAdminBuilderImplTest.java | 96 +++++++++++++
.../internal/http/AsyncHttpConnectorTest.java | 10 +-
pulsar-io/kinesis-kpl-shaded/pom.xml | 6 +
.../loadbalance/ExtensibleLoadManagerTest.java | 15 ++-
22 files changed, 763 insertions(+), 70 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/PersistentMessageExpiryMonitorMockTest.java
