This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 91bdc48 Fixed ZKSessionTest.testReacquireLocksAfterSessionLost
(#11886)
new 5a369be Forget to update memory usage on producer close (#11906)
new 9ce29f6 [testclient] deprecate option --subscriber-name and
substitute --subscriptions first element for it (#11828)
new 2cd8d47 [Transaction] add method to clear up transaction buffer
snapshot (#11934)
new 1703aff [Issue 11936] forget to call SendCallback on producer close
(#11939)
new 44d85e8 [C++] Handle error when shutting down client after forks
(#11954)
new b1ff9bc [Python] Expose Client.shutdown() method (#11955)
new d02653a Avoid to infinitely split bundle (#11937)
new b7c2c19 [pulsar-client]Add a optional params scope for pulsar oauth2
client (#11931)
new 0a57bae Print position info when can't find next valid position.
(#11969)
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 | 2 +-
.../loadbalance/impl/BundleSplitterTask.java | 8 +-
.../loadbalance/impl/ModularLoadManagerImpl.java | 2 +-
.../broker/service/persistent/PersistentTopic.java | 5 +-
.../pulsar/broker/systopic/SystemTopicClient.java | 19 ++++
.../TransactionBufferSystemTopicClient.java | 16 +++
.../transaction/buffer/TransactionBuffer.java | 7 ++
.../buffer/impl/InMemTransactionBuffer.java | 5 +
.../buffer/impl/TopicTransactionBuffer.java | 9 ++
.../buffer/impl/TransactionBufferDisable.java | 5 +
.../loadbalance/impl/BundleSplitterTaskTest.java | 105 +++++++++++++++++++
.../TopicTransactionBufferRecoverTest.java | 72 ++++++++++++-
.../pulsar/client/api/BrokerServiceLookupTest.java | 15 ++-
...MemoryLimitTest.java => ProducerCloseTest.java} | 37 ++++---
.../client/impl/ProducerMemoryLimitTest.java | 20 +++-
pulsar-client-cpp/lib/ExecutorService.cc | 20 ++--
pulsar-client-cpp/python/pulsar/__init__.py | 9 ++
pulsar-client-cpp/python/pulsar_test.py | 13 +++
.../apache/pulsar/client/impl/ProducerImpl.java | 29 +++---
.../auth/oauth2/AuthenticationFactoryOAuth2.java | 18 ++++
.../impl/auth/oauth2/ClientCredentialsFlow.java | 9 +-
.../protocol/ClientCredentialsExchangeRequest.java | 3 +
.../impl/auth/oauth2/protocol/TokenClient.java | 54 +++++++---
.../impl/auth/oauth2/protocol/TokenClientTest.java | 116 +++++++++++++++++++++
.../pulsar/testclient/PerformanceConsumer.java | 7 +-
site2/docs/reference-cli-tools.md | 2 +-
26 files changed, 534 insertions(+), 73 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTaskTest.java
copy
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/{ProducerMemoryLimitTest.java
=> ProducerCloseTest.java} (62%)
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/TokenClientTest.java
