This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 4bdaa32bc7c [improve][broker] Reduce the consumers list sort by
priority level (#16243)
new 4a02d47e269 [improve][broker] Make
PulsarWebResource#getOwnerFromPeerClusterList async. (#15940)
new 13a87905ce5 [Fix][broker] Fix NPE when ledger id not found in
`OpReadEntry` (#15837)
new 2251e6ebd7a [fix][client] Remove consumer when close consumer command
is received (#15761)
new 41f83ccc09e [fix][admin] Fix typo in validation message (#16021)
new eb60a55edf0 [fix][client] Remove producer when close producer command
is received (#16028)
new 68a8a31c30c rename
pulsar_producer_configuration_set_crypto_failure_action to
pulsar_producer_configuration_get_crypto_failure_action (#16031)
new cc9ff5965a1 [improve][broker] Avoid reconnection when a partitioned
topic was created concurrently (#16043)
new cec950eb3e6 [ML] Fix thread safety issues in ManagedCursorContainer
related to "heap" field access (#16049)
new 5f7a6afa2e3 [improve][tests] improved flaky test runs (#16011)
new 3c0063b4800 [Transaction] Set TC state is Ready after open
MLTransactionMetadataStore completely. (#13957)
new 51c1985356f [fix][broker]Fix topic policies update not check message
expiry (#15941)
new 718904dcef8 [fix][broker] Fix create client with TLS config (#16014)
new 028a42ca389 [Flakey-test] fix flaky-test RackAwareTest.testRackUpdate
(#16071)
new c5a6a0b78b3 [fix][txn] Fix NPE when ack message with transaction at
cnx = null (#16142)
new 4ce967ea672 [fix][broker][monitoring] fix message ack rate (#16108)
new b68fa32ea85 Fix `messageQueue` release message issue. (#16155)
new d7f996f8ae4 [fix][client] Fix the startMessageId can't be respected as
the ChunkMessageID (#16154)
new 5eefdf10e56 [fix][Java Client] Fix thread safety issue of
`LastCumulativeAck` (#16072)
new 6ed4ed05878 [improve][java-client] Only trigger the batch receive
timeout when having pending batch receives requests (#16160)
new 6b3ad13986d [fix][broker] Fix NPE when get
/admin/v2/namespaces/public/default/maxTopicsPerNamespace (#16076)
new ea20a896b40 [fix][client] Add classLoader field for `SchemaDefinition`
(#15915)
new 2198c337a2b [fix][tests] TieredStorageConfigurationTests - clear
system properties (#15957)
new 8856606d8f4 [fix][broker] Fix compaction subscription acknowledge
Marker msg issue. (#16205)
new b71f6113121 [fix][broker]Fix subscribe dispathcer limiter not be
initialized (#16175)
new b75af1772c1 [improve][broker] Avoid go through all the consumers to
get the message ack owner (#16245)
new 63f5289865a [improve][java-client] Replace ScheduledExecutor to
improve performance of message consumption (#16236)
new e83c26efcfc [improve][broker] Reduce the re-schedule message read
operation for PersistentDispatcherMultipleConsumers (#16241)
new a51196ecf4d [fix][broker] Fix NPE when drop backlog for time limit.
(#16235)
new 3048c876c2a [fix][broker]fix npe when invoke replaceBookie. (#16239)
The 29 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:
.../mledger/impl/ManagedCursorContainer.java | 16 +-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 6 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 10 +-
.../bookkeeper/mledger/impl/OpReadEntry.java | 4 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 28 ++++
.../IsolatedBookieEnsemblePlacementPolicy.java | 4 +
.../IsolatedBookieEnsemblePlacementPolicyTest.java | 33 ++++
.../org/apache/pulsar/broker/PulsarService.java | 11 +-
.../apache/pulsar/broker/admin/AdminResource.java | 2 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 3 +-
.../broker/service/AbstractBaseDispatcher.java | 17 +-
.../pulsar/broker/service/BacklogQuotaManager.java | 4 +
.../pulsar/broker/service/BrokerService.java | 17 +-
.../org/apache/pulsar/broker/service/Consumer.java | 42 +++--
.../PersistentDispatcherMultipleConsumers.java | 16 +-
.../broker/service/persistent/PersistentTopic.java | 2 +-
.../transaction/pendingack/PendingAckStore.java | 4 +-
.../pendingack/impl/InMemoryPendingAckStore.java | 4 +-
.../pendingack/impl/MLPendingAckStore.java | 4 +-
.../pendingack/impl/PendingAckHandleImpl.java | 4 +-
.../pulsar/broker/web/PulsarWebResource.java | 82 +++++-----
.../apache/pulsar/broker/admin/NamespacesTest.java | 2 +
.../pulsar/broker/service/MessageTTLTest.java | 34 +++-
.../pulsar/broker/service/RackAwareTest.java | 14 ++
.../service/SubscribeDispatchLimiterTest.java | 108 +++++++++++++
.../persistent/PersistentSubscriptionTest.java | 4 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 97 ++++++++----
.../pulsar/broker/transaction/TransactionTest.java | 54 ++++++-
.../client/api/ConsumerBatchReceiveTest.java | 47 ++++++
.../pulsar/client/api/MultiTopicsConsumerTest.java | 2 +-
.../pulsar/client/impl/MessageChunkingTest.java | 10 ++
.../apache/pulsar/compaction/CompactionTest.java | 70 +++++++++
.../functions/worker/PulsarFunctionTlsTest.java | 7 +-
.../apache/pulsar/io/PulsarFunctionTlsTest.java | 4 +-
.../pulsar/client/api/schema/SchemaDefinition.java | 7 +
.../client/api/schema/SchemaDefinitionBuilder.java | 9 ++
pulsar-client-cpp/lib/c/c_ProducerConfiguration.cc | 2 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 11 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 29 ++--
.../apache/pulsar/client/impl/ConsumerImpl.java | 32 +++-
.../client/impl/MultiTopicsConsumerImpl.java | 24 +--
.../PersistentAcknowledgmentsGroupingTracker.java | 141 +++++++++--------
.../pulsar/client/impl/PulsarClientImpl.java | 12 +-
.../pulsar/client/impl/schema/AvroSchema.java | 5 +-
.../impl/schema/SchemaDefinitionBuilderImpl.java | 15 +-
.../client/impl/schema/SchemaDefinitionImpl.java | 11 +-
.../pulsar/client/util/ExecutorProvider.java | 10 +-
.../client/util/ScheduledExecutorProvider.java | 17 +-
.../apache/pulsar/client/impl/ClientCnxTest.java | 38 +++++
.../pulsar/client/impl/LastCumulativeAckTest.java | 86 ++++++++++
.../client/impl/MultiTopicsConsumerImplTest.java | 2 +-
.../pulsar/client/impl/schema/AvroSchemaTest.java | 77 ++++++++-
.../client/impl/schema/SchemaBuilderTest.java | 8 +-
.../pulsar/sql/presto/PulsarRecordCursor.java | 14 +-
.../pulsar/sql/presto/TestPulsarConnector.java | 4 +-
.../impl/MLTransactionMetadataStore.java | 174 +++++++++++----------
.../impl/MLTransactionMetadataStoreProvider.java | 4 +-
.../MLTransactionMetadataStoreTest.java | 38 ++---
.../provider/TieredStorageConfigurationTests.java | 42 ++---
59 files changed, 1178 insertions(+), 400 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscribeDispatchLimiterTest.java
copy
pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaSinkContext.java
=>
pulsar-client/src/main/java/org/apache/pulsar/client/util/ScheduledExecutorProvider.java
(66%)
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/LastCumulativeAckTest.java
