This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 82550b106bd [fix][broker] Fix RawReader out of order (#16390)
new c95c98cdfad [fix][txn] Fix append txn message is lower than
lowWaterMark decrease pendingWriteOps (#16266)
new aa0294d984f [improve][broker] Use LinkedHashSet for config items of
type Set to preserve elements order (#16138)
new 4b592c827e6 [fix] [transaction] Cmd-Subscribe and Cmd-Producer will
not succeed even after 100 retries (#16248)
new 97dd4e0ba7c [fix][broker]fix bug: fail to expose managed ledger client
stats to prometheus if bookkeeperClientExposeStatsToPrometheus is true (#16219)
new 63a37624374 [improve][broker] Optimise msgOutCounter and
bytesOutCounter (#16214) (#16286)
new eba93cf7254 [fix][txn] Fix TopicTransactionBuffer ledger apend marker
throw ManagedLedgerAlreadyClosedException (#16265)
new cd690723171 fix select broker is none (#16316)
new 45fd4abf5da [improve][broker] Use shared broker client scheduled
executor provider (#16338)
new d6ff92223ba [fix][flaky-test] Fix failed test
PatternTopicsConsumerImplTest.testAutoSubscribePatternConsumer (#16375)
new f5beb2ba224 [fix][flaky-test] Try to fix flaky test related to
PersistentTopicTest.setup (#16383)
new 83be76fca25 [fix][flaky-test] Fix failed test
NonPersistentTopicE2ETest.testGCWillDeleteSchema (#16381)
new 4562d2586c1 [improve][java-client] Support passing existing scheduled
executor providers to the client (#16334)
new 1649ef47559 [improve][java-client] Improve performance of multi-topic
consumer with more than one IO thread (#16336)
new b5479ee6e45 Exclude the Netty Reactive Stream from asynchttpclient
(#16312)
new 9ee69c05d5c [fix][broker] Release the entry in
getEarliestMessagePublishTimeOfPos (#16386)
new 88b1636578c [fix][C++ client] Fix the close of Client might stuck or
return a wrong result (#16285)
new 7c37e5692a7 [improve][broker] Recycle OpReadEntry in some corner cases
(#16399)
new d60928fbf29 [fix][broker] Fix setManagedLedgerOffloadedReadPriority
not work. (#16436)
new 41c0cf343cc [fix][broker] fix No such ledger exception (#16420)
The 19 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 | 34 ++--
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 62 +++++++
pom.xml | 4 +
.../pulsar/broker/ManagedLedgerClientFactory.java | 4 +-
.../org/apache/pulsar/broker/PulsarService.java | 6 +
.../loadbalance/impl/ModularLoadManagerImpl.java | 6 +-
.../{Replicator.java => AbstractSubscription.java} | 36 ++---
.../pulsar/broker/service/AbstractTopic.java | 17 +-
.../org/apache/pulsar/broker/service/Consumer.java | 8 +
.../nonpersistent/NonPersistentSubscription.java | 6 +-
.../service/nonpersistent/NonPersistentTopic.java | 4 -
.../service/persistent/PersistentSubscription.java | 7 +-
.../broker/service/persistent/PersistentTopic.java | 5 +-
.../buffer/impl/TopicTransactionBuffer.java | 19 ++-
.../pendingack/impl/MLPendingAckReplyCallBack.java | 7 +-
.../broker/service/AbstractSubscriptionTest.java | 49 +++---
.../pulsar/broker/service/AbstractTopicTest.java | 75 +++++++++
.../apache/pulsar/broker/service/ConsumerTest.java | 77 +++++++++
.../broker/service/NonPersistentTopicE2ETest.java | 51 +++---
.../pulsar/broker/service/PersistentTopicTest.java | 3 +
.../pulsar/broker/stats/PrometheusMetricsTest.java | 32 +++-
.../pulsar/broker/transaction/TransactionTest.java | 179 +++++++++++++++++++++
.../buffer/TopicTransactionBufferTest.java | 89 ++++++++++
.../buffer/TransactionLowWaterMarkTest.java | 8 +
.../client/impl/PatternTopicsConsumerImplTest.java | 10 +-
.../common/naming/ServiceConfigurationTest.java | 3 +
pulsar-client-cpp/lib/ClientImpl.cc | 41 +++--
pulsar-client-cpp/lib/ReaderImpl.cc | 21 +--
pulsar-client-cpp/lib/ReaderImpl.h | 4 +-
pulsar-client-cpp/tests/ClientTest.cc | 32 ++++
pulsar-client-tools/pom.xml | 4 +
pulsar-client/pom.xml | 5 +
.../apache/pulsar/client/impl/MessagesImpl.java | 6 +-
.../client/impl/MultiTopicsConsumerImpl.java | 60 ++++---
.../pulsar/client/impl/PulsarClientImpl.java | 35 ++--
.../pulsar/client/impl/PulsarClientImplTest.java | 10 ++
.../common/policies/data/OffloadPoliciesImpl.java | 5 +
.../org/apache/pulsar/common/util/FieldParser.java | 6 +-
.../common/util/collections/FieldParserTest.java | 5 +
40 files changed, 859 insertions(+), 183 deletions(-)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/{Replicator.java
=> AbstractSubscription.java} (52%)
copy
pulsar-client-tools/src/test/java/org/apache/pulsar/admin/cli/TestCmdFunctionWorker.java
=>
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractSubscriptionTest.java
(50%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractTopicTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ConsumerTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/TopicTransactionBufferTest.java
