This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 72543fd19a6 [CI] Change python cp35-cp35m lib build version from
manylinux2014 to manylinux1 (#15180)
new 3782beb8804 Cleanup already deleted namespace topics. (#12597)
new eb6bde25772 [LoadBalance] Optimize find nics process. (#14340)
new 1c2eb897fb4 [fix][broker] filter the virtual NIC with relative path
(#14829)
new e5a7da92916 [fix][security] Upgrade jackson and jackson-databind
(2.13.2.1) to get rid of CVE-2020-36518 (#14871)
new b6f2d6ceaf5 [fix][pulsar-admin] Fix pulsar-admin not prompting message
when there is a 500 error. (#14856)
new cd835c59df1 [fix][client] ConsumerBuilderImpl can not set null to
deadLetterPolicy (#14980)
new c16f500939f [fix][broker] Fix potential NPE in Replicator (#15003)
new 59a1360c06f [fix][broker] Fix getPendingAckInternalStats redirect
issue. (#14876)
new fed8b8c3246 [fix][broker] Fix creating system namespace topic failure.
(#14949)
new ce56c0fb1c2 allow download package from package management service
(#14814)
new 03f49481e1c [fix][broker] Avoid heartbeat topic to offload. (#15008)
new 2c765d0d76e [improve][transaction] support configurable
``transactionBufferClientOperationTimeoutInMills`` (#15011)
new 9d0740b47a1 [improve][broker] Avoid using blocking calls for the async
method ``checkTopicOwnership`` (#15023)
new 98db8707cb0 [fix][broker] Return if reset in progress (#14978)
new 839b66385e6 [fix][transaction] Fix transaction REST API redirect
issue. (#15017)
new e5546279ed0 handle NPE when getLeader returns null (#15058)
new cfe2d2c2be7 Fix when nextValidLedger is null cause npe (#13975)
new d13baa7eb58 [fix][Transaction] Fix transaction admin redirect get 500
due to getCause (#14965)
new 944d9b8a45b [fix][broker] Fix rewind failed when
``redeliverUnacknowledgedMessages`` (#15046)
new 1df54b93be6 [improve][transaction] Optimize topic lookup when TC end
tx. (#14991)
new a6537f44fb7 [broker] fix parameter saslJaasBrokerSectionName in
broker.conf (#15110)
new ac0a242a0e9 fix debug log authenticate role error (#14784)
new 549692f8e4f [fix][security] Remove log4j for CVE-2022-23307 (#15109)
new 3adb09978e4 [fix][txn] TransactionMetadataService don't connect again
if store exist (#15114)
new 2dab3bae59a [improve][txn] Avoid create multiple future and exception
handler. (#15089)
new 70c4d0d9761 [C++] Fix UnknownError might be returned for a partitioned
producer (#15161)
The 26 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:
conf/broker.conf | 2 +-
deployment/terraform-ansible/templates/broker.conf | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 16 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 4 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 4 +
.../bookkeeper/mledger/impl/OffloadPrefixTest.java | 2 +-
pom.xml | 18 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 6 +
.../org/apache/pulsar/broker/PulsarService.java | 5 +-
.../broker/TransactionMetadataStoreService.java | 230 ++++-----
.../pulsar/broker/admin/impl/TransactionsBase.java | 539 ++++++++-------------
.../pulsar/broker/admin/v3/Transactions.java | 98 +++-
.../loadbalance/impl/LinuxBrokerHostUsageImpl.java | 32 +-
.../pulsar/broker/namespace/NamespaceService.java | 2 +-
.../pulsar/broker/namespace/OwnershipCache.java | 13 +-
.../pulsar/broker/service/AbstractReplicator.java | 2 +-
.../pulsar/broker/service/BrokerService.java | 31 +-
.../apache/pulsar/broker/service/ServerCnx.java | 18 +-
.../nonpersistent/NonPersistentReplicator.java | 2 +-
.../PersistentDispatcherSingleActiveConsumer.java | 19 +-
.../service/persistent/PersistentReplicator.java | 2 +-
.../buffer/impl/TransactionBufferClientImpl.java | 11 +-
.../buffer/impl/TransactionBufferHandlerImpl.java | 157 +++---
.../apache/pulsar/broker/web/RestException.java | 6 +-
.../org/apache/pulsar/broker/admin/AdminTest.java | 27 ++
.../v3/AdminApiTransactionMultiBrokerTest.java | 67 +++
.../broker/admin/v3/AdminApiTransactionTest.java | 115 ++++-
.../broker/namespace/OwnershipCacheTest.java | 2 +-
.../systopic/PartitionedSystemTopicTest.java | 68 ++-
.../broker/transaction/TransactionProduceTest.java | 29 ++
.../broker/transaction/TransactionTestBase.java | 2 +-
.../buffer/TransactionBufferClientTest.java | 39 +-
.../buffer/TransactionBufferHandlerImplTest.java | 39 +-
.../pulsar/broker/web/RestExceptionTest.java | 4 +-
.../client/api/SimpleProducerConsumerTest.java | 6 +-
.../pulsar/client/admin/internal/BaseResource.java | 2 +-
pulsar-client-cpp/lib/PartitionedProducerImpl.cc | 55 +--
pulsar-client-cpp/lib/PartitionedProducerImpl.h | 12 +-
pulsar-client-cpp/pulsar-test-service-start.sh | 4 +
pulsar-client-cpp/tests/ProducerTest.cc | 43 ++
.../pulsar/client/impl/ConsumerBuilderImpl.java | 3 +-
.../pulsar/client/impl/PulsarClientImpl.java | 10 +-
.../client/impl/ConsumerBuilderImplTest.java | 29 +-
pulsar-functions/runtime-all/pom.xml | 1 -
.../pulsar/functions/worker/FunctionActioner.java | 22 +-
.../pulsar/functions/worker/LeaderService.java | 3 +-
.../functions/worker/PulsarWorkerService.java | 4 +-
.../pulsar/functions/worker/WorkerUtils.java | 11 +-
.../functions/worker/rest/api/FunctionsImpl.java | 2 +-
.../functions/worker/rest/api/WorkerImpl.java | 9 +-
.../functions/worker/FunctionActionerTest.java | 49 ++
pulsar-io/elastic-search/pom.xml | 1 -
pulsar-sql/presto-distribution/LICENSE | 28 +-
pulsar-sql/presto-distribution/pom.xml | 4 +-
site2/docs/functions-worker.md | 4 +-
site2/docs/reference-configuration.md | 2 +-
site2/docs/security-kerberos.md | 8 +-
57 files changed, 1128 insertions(+), 797 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v3/AdminApiTransactionMultiBrokerTest.java
