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 c5f7271499e [improve][meta] PIP-453: Improve the metadata store
threading model (#25187)
new a8eac911968 [fix][test]Fix flaky
ExtensibleLoadManagerImplTest_testGetMetrics (#25216)
new 4332a44f177 [fix][broker] Fix ManagedCursorImpl.asyncDelete() method
may lose previous async mark delete properties in race condition (#25165)
new 1631fedda57 [fix][broker]Fix ledgerHandle failed to read by using new
BK API (#25199)
new 30ae8fba3f9 [fix][client] Fix producer synchronous retry handling in
failPendingMessages method (#25207)
new ba2a2303efe [fix][broker] Prevent missed topic changes in topic
watchers and schedule periodic refresh with patternAutoDiscoveryPeriod interval
(#25188)
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:
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 7 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 4 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 109 ++++++
.../impl/ManagedLedgerFactoryShutdownTest.java | 6 +
.../pulsar/broker/resources/PulsarResources.java | 8 +-
.../pulsar/broker/resources/TopicListener.java | 10 +-
.../pulsar/broker/resources/TopicResources.java | 83 ++++-
.../broker/resources/TopicResourcesTest.java | 103 ++++--
.../bucket/BookkeeperBucketSnapshotStorage.java | 2 +-
.../pulsar/broker/service/TopicListService.java | 375 ++++++++++++++-------
.../service/schema/BookkeeperSchemaStorage.java | 2 +-
.../pulsar/compaction/CompactedTopicImpl.java | 2 +-
.../extensions/ExtensibleLoadManagerImplTest.java | 4 +-
.../pulsar/broker/service/ServerCnxTest.java | 5 +-
.../broker/service/TopicListServiceTest.java | 363 +++++++++++++++++++-
.../broker/service/TopicListWatcherTest.java | 8 +-
.../testcontext/NonStartableTestPulsarService.java | 2 +-
...icWatcherBackPressureMultipleConsumersTest.java | 17 +-
.../impl/AutoCloseUselessClientConSupports.java | 9 +
...eUselessClientConTopicsPatternConsumerTest.java | 3 +
.../client/impl/PatternTopicsConsumerImplTest.java | 195 ++++++-----
.../pulsar/client/impl/ProducerSyncRetryTest.java | 99 ++++++
.../org/apache/pulsar/client/impl/ClientCnx.java | 15 +
.../client/impl/PatternConsumerUpdateQueue.java | 176 +++++++---
.../impl/PatternMultiTopicsConsumerImpl.java | 216 ++++++++----
.../apache/pulsar/client/impl/ProducerImpl.java | 20 +-
.../pulsar/client/impl/PulsarClientImpl.java | 9 +-
.../pulsar/client/impl/TopicListWatcher.java | 75 ++++-
.../pulsar/client/impl/ClientTestFixtures.java | 16 +-
.../impl/PatternConsumerUpdateQueueTest.java | 74 ++--
.../impl/PatternMultiTopicsConsumerImplTest.java | 268 ++++++++++++++-
.../pulsar/client/impl/ProducerImplTest.java | 77 +++++
.../pulsar/client/impl/TopicListWatcherTest.java | 81 ++++-
.../apache/pulsar/common/protocol/Commands.java | 1 +
.../org/apache/pulsar/common/topics/TopicList.java | 2 +-
pulsar-common/src/main/proto/PulsarApi.proto | 5 +-
.../impl/AutoCloseUselessClientConProxyTest.java | 5 +
37 files changed, 1961 insertions(+), 495 deletions(-)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/NoSwaggerDocumentation.java
=>
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/TopicListener.java
(69%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ProducerSyncRetryTest.java
