This is an automated email from the ASF dual-hosted git repository.
daojun pushed a change to branch dev/grpc_schema_storage
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from e1d49c1245e Introduce gRPC SchemaStorage
add d4bbf10f587 [fix][client] Fix negative acknowledgement by messageId
(#23060)
add e59cd05881b [fix] [broker] Remove blocking calls from
Subscription.getStats (#23088)
add 679a3d49eef [improve] [broker] Check max producers/consumers
limitation first before other ops to save resources (#23074)
add 76ed555e7e5 [improve][build] Upgrade docker-maven-plugin to 0.45.0
(#23091)
add a0bdf4585fe [improve][ci] Switch to use DEVELOCITY_ACCESS_KEY from
GRADLE_ENTERPRISE_ACCESS_KEY (#23090)
add 40c8c23123e [improve][broker] Reduce the CPU pressure from the
transaction buffer in rolling restarts (#23062)
add 77b6378ae8b [improve][broker] Optimize the performance of individual
acknowledgments (#23072)
add 49d3beb4fae [improve][broker] Support to specify auth-plugin,
auth-parameters and tls-enable arguments when init cluster metadata (#23087)
add b955c6520d8 [fix] [broker] Internal reader of __change_events can not
started after metadata store session rebuilt (#23018)
add 47d35a0af8e [improve][build] Move docker-push profile to submodule
(#23093)
add 19fe2e40392 [cleanup][broker] Remove PersistentSubscription.getStats
(#23095)
add 6bbaec1f6b1 [fix][client] TransactionCoordinatorClient support retry
(#23081)
new 3d34484df52 Merge branch 'refs/heads/master' into
dev/grpc_schema_storage
The 1 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:
.github/workflows/ci-maven-cache-update.yaml | 2 +-
.github/workflows/ci-owasp-dependency-check.yaml | 2 +-
.github/workflows/pulsar-ci-flaky.yaml | 2 +-
.github/workflows/pulsar-ci.yaml | 20 +-
.mvn/extensions.xml | 2 +-
docker/pulsar-all/pom.xml | 4 +-
docker/pulsar/pom.xml | 4 +-
pom.xml | 2 +-
.../apache/pulsar/PulsarClusterMetadataSetup.java | 51 ++-
.../org/apache/pulsar/broker/PulsarService.java | 2 +-
.../extensions/ExtensibleLoadManagerImpl.java | 3 +-
.../loadbalance/impl/ModularLoadManagerImpl.java | 3 +-
.../pulsar/broker/service/AbstractTopic.java | 20 +-
.../org/apache/pulsar/broker/service/Consumer.java | 151 ++++----
.../apache/pulsar/broker/service/ServerCnx.java | 19 +
.../SystemTopicTxnBufferSnapshotService.java | 15 +-
.../TransactionBufferSnapshotServiceFactory.java | 26 +-
.../service/persistent/PersistentSubscription.java | 54 ++-
.../broker/service/persistent/PersistentTopic.java | 108 +++---
.../SingleSnapshotAbortedTxnProcessorImpl.java | 73 +---
.../SnapshotSegmentAbortedTxnProcessorImpl.java | 394 +++++++++------------
.../broker/transaction/buffer/impl/TableView.java | 97 +++++
.../buffer/impl/TopicTransactionBuffer.java | 5 +-
.../java/org/apache/pulsar/utils/SimpleCache.java | 83 +++++
.../apache/pulsar/broker/admin/AdminApi2Test.java | 77 +++-
.../apache/pulsar/broker/service/Ipv4Proxy.java | 197 +++++++++++
...SyncTestBase.java => NetworkErrorTestBase.java} | 223 +++++++-----
.../pulsar/broker/service/PersistentTopicTest.java | 79 ++---
.../pulsar/broker/service/ZkSessionExpireTest.java | 184 ++++++++++
.../TopicTransactionBufferRecoverTest.java | 46 ++-
.../TransactionCoordinatorClientTest.java | 24 ++
.../broker/zookeeper/ClusterMetadataSetupTest.java | 43 +++
...toCreateTopicTest.java => MaxProducerTest.java} | 57 +--
.../pulsar/client/impl/NegativeAcksTest.java | 13 +-
.../org/apache/pulsar/utils/SimpleCacheTest.java | 81 +++++
.../apache/pulsar/client/impl/ConsumerImpl.java | 2 +-
.../client/impl/TransactionMetaStoreHandler.java | 26 +-
.../TransactionCoordinatorClientImpl.java | 4 +-
.../metadata/impl/AbstractMetadataStore.java | 10 +
39 files changed, 1488 insertions(+), 720 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TableView.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/utils/SimpleCache.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/Ipv4Proxy.java
copy
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/{GeoReplicationWithConfigurationSyncTestBase.java
=> NetworkErrorTestBase.java} (52%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ZkSessionExpireTest.java
copy
pulsar-broker/src/test/java/org/apache/pulsar/client/api/{SimpleProducerConsumerDisallowAutoCreateTopicTest.java
=> MaxProducerTest.java} (59%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/utils/SimpleCacheTest.java
