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 c604310c88c [improve][proxy] Add regression tests for package upload
with 'Expect: 100-continue' (#25211)
new ab27ec90e8b [fix][test]Fix flaky
ExtensibleLoadManagerImplTest_testGetMetrics (#25216)
new 2f474463abb [fix][broker] Fix ManagedCursorImpl.asyncDelete() method
may lose previous async mark delete properties in race condition (#25165)
new 5bd426ac7b6 [fix][broker]Fix ledgerHandle failed to read by using new
BK API (#25199)
new 2ad42019780 [fix][client] Fix producer synchronous retry handling in
failPendingMessages method (#25207)
new eaf42b2569c [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
