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 affd047 Fixes NPE - ``ReplicatedSubscriptionsController`` send marker
message when enable deduplicated. (#14017)
new 32a9d52 [pulsar-broker] clean up active consumer on already closed
connection (#13196)
new be26fad Fix batch message ack does not decrease the unacked-msg
count. (#13383)
new e9b9512 [Transaction] PendingAckHandleImpl handle isInCacheRequest
(#13481)
new 1aecf92 Allow to configure schema compatibility policy for system
topics (#12598)
new 44d3c59 [Broker] Fix read schema compatibility strategy priority
(#13938)
new 3549764 [Transaction] RetryException should not be return (#13828)
new 137200b Trim configuration value string which contains blank prefix
or suffix string (#13984)
new fa549f6 [Transaction] Resolve the performance bottleneck of
TransactionBufferHandle (#13988)
new 84f5de6 [Transaction] Add transaction admin (#13447)
new df232a0 Fixed handling of consumers with equal names on on key shared
selector with consistent hashing (#13991)
The 10 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 | 11 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 18 +-
.../org/apache/pulsar/broker/PulsarService.java | 18 +-
.../broker/TransactionMetadataStoreService.java | 21 +-
.../apache/pulsar/broker/admin/AdminResource.java | 15 +
.../pulsar/broker/admin/impl/NamespacesBase.java | 11 +-
.../broker/admin/impl/SchemasResourceBase.java | 42 +--
.../pulsar/broker/service/AbstractTopic.java | 32 +-
...ConsistentHashingStickyKeyConsumerSelector.java | 2 +-
.../org/apache/pulsar/broker/service/Consumer.java | 129 +++++++-
.../org/apache/pulsar/broker/service/Topic.java | 5 +
.../service/persistent/PersistentSubscription.java | 8 +-
.../broker/service/persistent/PersistentTopic.java | 10 +
.../buffer/impl/TopicTransactionBuffer.java | 5 +-
.../buffer/impl/TransactionBufferHandlerImpl.java | 55 +---
.../transaction/pendingack/PendingAckHandle.java | 15 +-
.../pendingack/impl/MLPendingAckReplyCallBack.java | 6 +-
.../pendingack/impl/PendingAckHandleDisabled.java | 12 +-
.../pendingack/impl/PendingAckHandleImpl.java | 331 ++++++++++-----------
.../recover/TransactionRecoverTrackerImpl.java | 6 +-
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 20 +-
.../pulsar/broker/admin/AdminApiSchemaTest.java | 53 ++++
.../pulsar/broker/service/BatchMessageTest.java | 2 +-
.../BatchMessageWithBatchIndexLevelTest.java | 108 +++++++
.../PersistentDispatcherFailoverConsumerTest.java | 79 ++---
.../TransactionMetadataStoreServiceTest.java | 14 +-
.../persistent/PersistentSubscriptionTest.java | 5 +-
.../broker/stats/TransactionMetricsTest.java | 6 +-
.../NamespaceEventsSystemTopicServiceTest.java | 25 ++
.../pulsar/broker/transaction/TransactionTest.java | 41 +++
.../pendingack/PendingAckPersistentTest.java | 1 +
.../client/api/KeySharedSubscriptionTest.java | 72 +++++
.../client/impl/BrokerClientIntegrationTest.java | 54 ++++
.../SchemaCompatibilityCheckTest.java | 6 +-
.../SchemaTypeCompatibilityCheckTest.java | 8 +-
.../pulsar/common/policies/data/Policies.java | 3 +-
.../policies/data/SchemaCompatibilityStrategy.java | 5 +-
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 1 +
.../org/apache/pulsar/common/util/FieldParser.java | 8 +-
.../apache/pulsar/common/util/FieldParserTest.java | 40 +++
40 files changed, 896 insertions(+), 407 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java
