This is an automated email from the ASF dual-hosted git repository.
xyz pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from b06b2ee056a Update/fix Swagger Annotation for param: authoritative
(#16222)
new 688bfa39774 [fix][broker]Fix getInternalStats occasional lack of
LeaderInfo again (#16238)
new c0eef81e6a5 [fix][C++ client] Fix the close of Client might stuck or
return a wrong result (#16285)
new 7f9cd930594 [fix][broker] Fix setManagedLedgerOffloadedReadPriority
not work. (#16436)
new 0dc2cede6c7 [fix][broker] fix No such ledger exception (#16420)
new fbba81446b9 [improve][test] Fix flaky C++ ClientTest.testWrongListener
(#16510)
new 003e1737410 [fix][pulsar-broker] Fix RawReader hasMessageAvailable
returns true when no messages (#16443)
new aa0b3f6cee9 [fix][proxy] Do not preserve host when forwarding admin
requests. (#16342)
new 2d457765121 [fix][broker] Fix stats-internal with option -m cause
active ledger recover then close (#16662)
new cb12e2fd87c [fix][client] Fix ReconsumeLater will hang up if
retryLetterProducer exception (#16655)
The 9 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/ManagedLedgerImpl.java | 49 ++++++++++----
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 17 +++++
.../broker/service/persistent/PersistentTopic.java | 76 +++++++++++-----------
.../apache/pulsar/client/impl/RawReaderImpl.java | 3 +
.../apache/pulsar/client/api/RetryTopicTest.java | 60 +++++++++++++++++
.../apache/pulsar/client/impl/RawReaderTest.java | 52 +++++++++++++++
.../common/naming/ServiceConfigurationTest.java | 3 +
pulsar-client-cpp/lib/ClientImpl.cc | 45 +++++++------
pulsar-client-cpp/lib/ReaderImpl.cc | 21 +++---
pulsar-client-cpp/lib/ReaderImpl.h | 4 +-
pulsar-client-cpp/tests/ClientTest.cc | 34 ++++++++++
.../apache/pulsar/client/impl/ConsumerImpl.java | 8 +--
.../common/policies/data/OffloadPoliciesImpl.java | 5 ++
.../pulsar/proxy/server/ProxyServiceStarter.java | 1 -
.../proxy/server/AuthedAdminProxyHandlerTest.java | 1 -
.../SuperUserAuthedAdminProxyHandlerTest.java | 1 -
.../server/UnauthedAdminProxyHandlerTest.java | 1 -
17 files changed, 289 insertions(+), 92 deletions(-)
