This is an automated email from the ASF dual-hosted git repository.
bogong pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
omit e3611cb8517 fix `DnsResolverTest` license header
omit bc35faaadb3 [improve][schema] Change update schema auth from tenant to
produce (#18074)
omit d698ac79d4d [fix][broker] DnsResolverUtil.TTL should be greater than
zero (#18565)
omit 5cf8e26cb26 fix the presto-distribution license protobuf-java version
omit 47f9041bbd9 [fix] Avoid redelivering duplicated messages when batching
is enabled (#18486)
omit 0896eda18c1 [fix][schema] Fix cherry-pick issue from #18283 (#18555)
omit 643787e931d [fix][broker] Make `deleteTopicPolicies` serialized is
executed when close topic. (#15811)
omit 97a4bbf06f4 [fix][client] Fix multi-topic consumer stuck after
redeliver messages (#18491)
omit 961d5b5094b fix #18491 import incorrect class
omit 975f643b97f [fix][client] Fix multi-topic consumer stuck after
redeliver messages (#18491)
omit 5f777fb7b50 [fix][client] Fix failover/exclusive consumer with batch
cumulate ack issue. (#18454)
omit 4da92ef4222 [refactor][java] Improve docs and code quality about
KeyValueSchema usages (#17256)
omit 803aafe76a8 [fix][client] Fix possible npe (#18406)
omit d739559278e [fix][security] Bump PostgreSQL version to 42.4.1(#17066)
omit ce8e8916663 [fix][ml] Persist correct markDeletePosition to prevent
message loss (#18237)
omit 3ab0b2d3cf1 [fix][broker] Fix broker cache eviction of entries read by
active cursors (#17273)
omit f33fa7305d6 [improve][broker] refactor ManagedLedger cacheEvictionTask
implement (#14488)
omit bd0c56a3145 [enh][broker] Add metrics for entry cache insertion,
eviction (#17248)
omit ee5f5d251c4 Extracted interface for EntryCacheManager (#15933)
omit 887e4d99838 [pulsar-broker] Broker extensions to allow operators of
enterprise wide cluster better control and flexibility (#12536)
omit f31a6fae95e Add a cache eviction policy：Evicting cache data by the
slowest markDeletedPosition (#14985)
omit 5093c07abf2 Support dynamic update cache config (#13679)
omit 31c0a2ea97a [fix][offload] Fix memory leak while Offloading ledgers
(#18500)
omit 4a0891190ca [fix][client] Fix exception when calling loadConf on a
ConsumerBuilder that has a KeySharedPolicy (#18345)
omit 8324e65c30a [improve][test] Add subscribing regex topic test for
`delete_when_subscriptions_caught_up`. (#18368)
omit 3cf167a4b08 [fix][broker] fix delete_when_subscriptions_caught_up
doesn't work while have active consumers (#18320)
omit 9ae2f403ee4 fix flaky test testFailoverSingleAckedPartitionedTopic
omit f45b20463bd fix test `testPulsarServicePulsarClientConfiguration`
omit 1b41225e6cc [fix][sec] [branch-2.9] Bump snakeyaml to 1.32 for
CVE-2022-38752 (#18467)
omit 72523251bc3 fix testEmptyStringAsExtractionDirectory power mock
omit cdc1ee39d4c [fix] [python client] Better Python garbage collection
management for C++-owned objects (#16535)
omit 309d0f3f04e Fix broken C++ unit tests
omit 08c7992ca84 [improve][broker] Improve naming for delete topic error
(#16965)
omit b0a8c9fe17d [fix][client] Fixes batch_size not checked in
MessageId#fromByteArrayWithTopic (#18405)
omit cc37fb48dac [fix][broker]Cache invalidation due to concurrent access
(#18076)
omit fef77939ad0 [fix][broker] Update the log print content of
createSubscriptions (#18024)
omit 60211a593ad [fix][broker] Fix the order of resource close in the
InMemoryDelayedDeliveryTracker (#18000)
omit cf92d1369a0 [docs] [ISSUE 12366] Add doc of bundles metrics (#12825)
omit d6c85667e8e [fix][broker]unify time unit at dropping the backlog on a
topic (#17957)
omit 4501f3986b1 [improve][client] Refactor SchemaHash to reduce call of
hashFunction in SchemaHash (#17948)
omit 15245f3f2ac Revert "fix:
org.apache.kafka.connect.errors.DataException: Invalid Java object for schema
with type... (#15598)"
omit 417042b35d4 fix: org.apache.kafka.connect.errors.DataException:
Invalid Java object for schema with type... (#15598)
omit 676f04b9374 [fix][broker]Fix mutex never released when trimming
(#17911)
omit 80f30e40012 [improve][broker]Improve PersistentMessageExpiryMonitor
expire speed when ledger not existed (#17842)
omit 651e71956d6 [fix][admin] returns 4xx error when pulsar-worker-service
is disabled and trying to access it (#17901)
omit 54ecc2d19a1 [improve][ML] Print log when delete empty ledger. (#17859)
omit b4d8928f93c [refactor][java] Unify the acknowledge process for batch
and non-batch message IDs (#17833)
omit 2a8706ceb28 [fix][cli] Check numMessages after incrementing counter
(#17826)
omit 5c4551e0de6 [fix][cli] Quit PerformanceConsumer after receiving
numMessages messages (#17750)
omit ce549f8e54b [fix][broker] add return for
PersistentMessageExpiryMonitor#findEntryFailed
omit 3844a746b97 [Improve][Auth]Update authentication failed metrics report
(#17787)
omit f9e9dcda234 ManagedLedger: move to FENCED state in case of
BadVersionException (#17736)
omit cc97adfa5b5 [fix][client] Unwrap completion exception for Lookup
Services (#17717)
omit e047dabc7fd [fix][broker] Fix if dynamicConfig item in ZK do not exist
in broker cause NPE (#17705)
omit 17a72a7334b [bugfix] Prevent Automatic Topic Creation during namespace
deletion (#17609)
omit 4c3e56b155a [fix][client]Fix scheduledExecutorProvider not shutdown
(#17527)
omit bcd0b74ca7b [fix][broker]Consumer can't consume messages because there
has two sames topics in one broker (#17526)
omit 6fc4b6d42f0 [fix][cpp] Fix issue where unexpected ack timeout occurred
(#17503)
omit 3516e27ec8e [fix][cpp] Use weak ptr avoid circular references. (#17481)
omit aecbe4b9895 [fix][broker] Extract additional servlets to the default
directory by… (#17477)
omit e6364bc41f0 [fix][storage]fix OpAddEntry release error when exception
in ManagedLedgerInterceptor (#17929)
omit 863ea603abb fix can not revoke permission after update topic partition
(#17608)
omit ab568221c9d [fix][schema]ledger handle leak when update schema (#17283)
omit cf95d12257f [fix][fn] fix function failed to start if no
`typeClassName` provided in `FunctionDetails` (#18111)
omit 702bbe91e6a [fix][broker] Pass subscriptionName to auth service
(#17123)
omit 6f24812fbe9 [fix][broker] Increment topic stats outbound message
counters after messages have been written to the TCP/IP connection (#17043)
omit aae0c69c5c6 [fix][flaky-test]
ElasticSearchClientTests.testBulkBlocking (#16920)
omit a70caead8c5 [improve][test] Verify the authentication data in the
authorization provider (#16900)
omit 7d405c3518a [Broker] Fix NPE of internalExpireMessagesByTimestamp
(#14243)
omit 92c9cf93064
[fix][flaky-test]ManagedCursorMetricsTest.testManagedCursorMetrics (#16878)
omit e12642afb85 [fix][sec] Upgrade jackson-databind to 2.13.4.2 to get rid
of CVE-2022-42003 (#18394)
omit 67ee852fbc6 fix Flaky-test:
PulsarFunctionLocalRunTest.testE2EPulsarFunctionLocalRunMultipleInstance
(#16872)
omit 4f708bd9c76 Forget to update memory usage when invalid message (#16835)
omit b4ce1b79918 [fix][flaky-test] Fix ClassCastException: BrokerService
cannot be cast to class PulsarResources (#16821)
omit 0c6f89921d2 [improve] clean the empty topicAuthenticationMap in zk
when revoke permission (#16815)
omit 4d4f1896e42 Skip creating a subscription replication snapshot if no
messages have been published after the topic gets activated on a broker (#16618)
omit 69ff4dbdf79 [improve][broker] Use shared broker client scheduled
executor provider (#16338)
omit a75a22ddd5f [Broker] Use shared executors for broker and
geo-replication clients (#13839)
omit df3e2cea1da Disable stats recorder for built-in PulsarClient (#12217)
omit a58894a859c [improve][java-client] Support passing existing scheduled
executor providers to the client (#16334)
omit 40b3e4e44ba [improve][broker] Reduce the re-schedule message read
operation for PersistentDispatcherMultipleConsumers (#16241)
omit f26fe8fd2b7 [fix][test] Catch exception when update data in
mockZookeeper (#16473)
omit 33f30737616 [improve][java-client] Only trigger the batch receive
timeout when having pending batch receives requests (#16160)
omit d89214890bd [improve][java-client] Improve performance of multi-topic
consumer with more than one IO thread (#16336)
omit ca76f455128 [improve][java-client] Replace ScheduledExecutor to
improve performance of message consumption (#16236)
omit 97fdb483e02 [Client] Support passing existing executor providers to
the client (#12037)
omit ad09404ca6d [improve][broker] Reduce the consumers list sort by
priority level (#16243)
omit 54561f0ad70 [fix][flaky-test]
BrokerInterceptorTest.testProducerCreation (#16742)
omit dcfe765ad0a [improve][test] Reduce the time consumption of
BacklogQuotaManagerTest (#16550)
omit 7addfcd03c2 Issue 17588: Allow deletion of a namespace that was left
in deleted status (#17592)
omit ca4a5d18969 [Broker] Do not create missing topic when loading
namespace (#13948)
omit 6cf312c5ae5 [fix][client] Support LocalDateTime Conversion (#18334)
omit e5ba1a0a47e [fix][broker] Fix namespace backlog quota check with
retention. (#17706)
omit 0eeea1a295c [fix] [pulsar-client] Fix pendingLookupRequestSemaphore
leak when Ser… (#18219)
omit 98c1629f9ae [fix][broker] Unregister topic policy listener if managed
ledger close failed (#17652)
omit 24f951049f4 cherry-pick -x "3c3ec49"
omit 4420dd0de81 cherry-pick -x "628e760"
omit 26343569a86 [fix][broker] Fix executeWithRetry result is null (#17694)
omit 505542718e1 [fix][tiered-storage] Don't cleanup data when offload met
Metastore exception (#17512)
omit f1882ee4f03 cherry-pick -x "882fcfb"
omit b48d4199b0b cherry-pick -x "6c65ca0"
omit 3f22204cb4d [fix][function] Fix invalid metric type `gauge ` (#18129)
omit f00bcc44460 [improve][txn] Implementation of Delayed Transaction
Messages (#17548)
omit e9d87fa09d9 Fix metadata cache inconsistency on do refresh (#14283)
omit aede60f7092 fix-12894 (#12896)
omit 58d0cbf2d1a [fix][broker] Fix issue where leader broker information
isn't available after 10 minutes (#17401)
omit 88b1a96412f Ensure cache is refreshed (and not just invalidated) after
a store write (#12788)
omit a87fadd25c2 cherry-pick/#17659 (#18391)
omit cf55b3a9e62 Fix NPE when get OffloadThreshold on namespace (#18387)
omit 8339e846528 [cherry-pick][branch-2.9] Fix NPE when
ResourceGroupService execute scheduled task. (#18389)
omit bf54c696052 cherry-pick -x "70530d4"
omit dac1fe84e37 [fix][cpp] Fix flaky testReferenceCount (#17645)
omit b99f050570e fix comments for exposeManagedLedgerMetricsInPrometheus
field (#17792)
omit 825df41ab7e [fix][broker] Fix `getPositionAfterN` infinite loop.
(#17971)
omit 40ade12fa66 cherry-pick -x "b451880"
omit c85731dd135 [fix] [pulsar-client] Fix pendingLookupRequestSemaphore
leak when channel inactive (#17856)
omit ec3d03d96e0 cherry-pick -x "67a3de7"
omit 98309d4dc09 [fix][broker] In the trimDeletedEntries method, release
the removed entry (#18305)
omit 3cfa13c1642 [fix][flaky-test]ConsumedLedgersTrimTest (#17116)
omit 128f385c8cc cherry-pick -x "84968e8"
omit e146f16e352 cherry-pick -x "de6948c"
omit 93b69cccee6 cherry-pick -x "1faf497"
omit 3dd077c6be2 [improve][txn] Add getState in transaction for client API
(#17423)
omit 458ff57f235
[fix][flaky-test]BatchMessageWithBatchIndexLevelTest.testBatchMessageAck
(#17436)
omit e5033aa5072 [fix][test]Fix
ManagedLedgerTest#avoidUseSameOpAddEntryBetweenDifferentLedger (#16720)
omit e665892c56e Fix Flaky-test:
ManagedLedgerBkTest.asyncMarkDeleteAndClose. (#16730)
omit 5b4d885b052 [fix][flaky-test] Fix PulsarFunctionTlsTest.tearDown
(#16765)
omit a38183d5881 [fix][flaky-test] Fix
PersistentTopicStreamingDispatcherTest (#16801)
omit 97331f2fbef Fix Flaky-test:
PartitionedProducerConsumerTest.testPartitionedTopicInterceptor. (#16809)
omit cff0e836bd3 [fix][txn] fix ack with txn compute ackedCount error
(#17016)
omit 3fe62401d7f [fix][test] Fix jvm oom on Unit Test broker group 1
(#16542)
omit 713dbde69e3 [fix][flaky-test]
PersistentFailoverE2ETest.testSimpleConsumerEventsWithPartition (#16493)
omit e7c63d35eb2 cherry-pick -x "7c9ad1c"
omit 95f3b06cfac [improve][broker] Avoid go through all the consumers to
get the message ack owner (#16245)
omit cf6f3f6e0c3 Fix flaky-test: NonPersistentTopicE2ETest.testGC (#16505)
omit ba2d9dbe7c5 [fix][flaky-test] Fix flaky test
testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#16419)
omit 07ab175b584 [fix][flaky-test] Fix failed test
PatternTopicsConsumerImplTest.testAutoSubscribePatternConsumer (#16375)
omit a72b535b83d [fix][flaky-test] testSplitBundleForMultiTimes (#16562)
omit a8fb6586563 [fix][flaky-test] Try to fix flaky test related to
PersistentTopicTest.setup (#16383)
omit ab96b897b43 cherry-pick -x "aabd5d0"
omit 1c6d0933956 [fix][flaky-test] Fix failed test
NonPersistentTopicE2ETest.testGCWillDeleteSchema (#16381)
omit fa2aa81f7cf [improve][admin] Fix NPE in admin-CLI topic stats command
(#18326)
omit 750a54fa248 Merge branch 'branch-2.9' of
https://github.com/apache/pulsar into branch-2.9
omit 14824a5adbd [improve][broker]consumer backlog eviction policy should
not reset read position for consumer (#18350)
omit d6cf1697bb0 [improve][tests] improved flaky test runs (#16011)
omit 3a936bc90d5 cherry-pick 4721ce1
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/branch-2.9 (5ed247de3a5)
\
O -- O -- O (e3611cb8517)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 -
bin/function-localrunner | 2 +-
buildtools/pom.xml | 2 +-
conf/bkenv.sh | 2 +-
conf/broker.conf | 9 +-
conf/pulsar_env.sh | 2 +-
deployment/terraform-ansible/templates/broker.conf | 7 +-
.../terraform-ansible/templates/pulsar_env.sh | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 4 +-
.../apache/bookkeeper/mledger/ManagedLedger.java | 7 -
.../bookkeeper/mledger/ManagedLedgerConfig.java | 6 -
.../bookkeeper/mledger/ManagedLedgerException.java | 10 -
.../bookkeeper/mledger/ManagedLedgerFactory.java | 18 -
.../mledger/ManagedLedgerFactoryConfig.java | 4 +-
.../mledger/ManagedLedgerFactoryMXBean.java | 15 -
.../mledger/impl/{cache => }/EntryCache.java | 4 +-
.../EntryCacheDefaultEvictionPolicy.java | 4 +-
.../impl/{cache => }/EntryCacheEvictionPolicy.java | 2 +-
...angeEntryCacheImpl.java => EntryCacheImpl.java} | 38 +-
.../bookkeeper/mledger/impl/EntryCacheManager.java | 266 +++++++++
.../mledger/impl/ManagedCursorContainer.java | 129 ++---
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 89 ++-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 54 +-
.../impl/ManagedLedgerFactoryMBeanImpl.java | 27 -
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 301 ++++------
.../mledger/impl/NonDurableCursorImpl.java | 2 +-
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 20 -
.../mledger/impl/cache/EntryCacheDisabled.java | 147 -----
.../mledger/impl/cache/EntryCacheManager.java | 39 --
.../impl/cache/RangeEntryCacheManagerImpl.java | 199 -------
.../mledger/impl/cache/package-info.java | 19 -
.../intercept/ManagedLedgerInterceptor.java | 35 --
.../apache/bookkeeper/mledger/util/RangeCache.java | 19 +-
.../mledger/impl/EntryCacheManagerTest.java | 154 +++--
.../bookkeeper/mledger/impl/EntryCacheTest.java | 4 +-
.../mledger/impl/ManagedCursorContainerTest.java | 71 +--
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 130 +----
.../mledger/impl/ManagedLedgerBkTest.java | 15 +-
.../mledger/impl/ManagedLedgerErrorsTest.java | 70 ---
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 283 +---------
.../bookkeeper/mledger/impl/OffloadPrefixTest.java | 48 --
.../bookkeeper/mledger/util/RangeCacheTest.java | 5 +-
.../bookkeeper/test/MockedBookKeeperTestCase.java | 4 -
pom.xml | 10 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 40 +-
.../authentication/AuthenticationProviderList.java | 8 -
.../web/plugin/servlet/AdditionalServlets.java | 3 +-
.../web/plugin/servlet/AdditionalServletsTest.java | 92 ---
.../pulsar/broker/ManagedLedgerClientFactory.java | 2 +-
.../org/apache/pulsar/broker/PulsarService.java | 55 +-
.../apache/pulsar/broker/admin/AdminResource.java | 19 +-
.../pulsar/broker/admin/impl/FunctionsBase.java | 2 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 3 +-
.../broker/admin/impl/PersistentTopicsBase.java | 46 +-
.../broker/admin/impl/SchemasResourceBase.java | 2 +-
.../apache/pulsar/broker/admin/impl/SinksBase.java | 2 +-
.../pulsar/broker/admin/impl/SourcesBase.java | 2 +-
.../apache/pulsar/broker/admin/v2/Functions.java | 2 +-
.../org/apache/pulsar/broker/admin/v2/Worker.java | 4 +-
.../apache/pulsar/broker/admin/v2/WorkerStats.java | 2 +-
.../delayed/InMemoryDelayedDeliveryTracker.java | 9 +-
.../pulsar/broker/intercept/BrokerInterceptor.java | 65 ---
.../BrokerInterceptorWithClassLoader.java | 43 --
.../broker/intercept/BrokerInterceptors.java | 74 ---
.../intercept/ManagedLedgerInterceptorImpl.java | 63 +--
.../loadbalance/impl/ModularLoadManagerImpl.java | 10 +-
.../pulsar/broker/namespace/NamespaceService.java | 5 +-
.../broker/resourcegroup/ResourceGroupService.java | 38 +-
.../broker/service/AbstractBaseDispatcher.java | 4 +-
.../pulsar/broker/service/BacklogQuotaManager.java | 18 +-
.../pulsar/broker/service/BrokerService.java | 162 +-----
.../org/apache/pulsar/broker/service/Consumer.java | 59 +-
.../org/apache/pulsar/broker/service/Producer.java | 36 --
.../apache/pulsar/broker/service/ServerCnx.java | 27 +-
.../org/apache/pulsar/broker/service/Topic.java | 7 -
.../service/nonpersistent/NonPersistentTopic.java | 9 +-
.../PersistentDispatcherMultipleConsumers.java | 8 +-
.../persistent/PersistentMessageExpiryMonitor.java | 25 +-
.../broker/service/persistent/PersistentTopic.java | 215 ++++---
.../ReplicatedSubscriptionsController.java | 3 +-
.../service/schema/BookkeeperSchemaStorage.java | 13 +-
.../broker/stats/AllocatorStatsGenerator.java | 4 +-
.../stats/metrics/ManagedLedgerCacheMetrics.java | 7 +-
.../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 | 8 +-
.../pulsar/broker/MultiBrokerTestZKBaseTest.java | 61 --
.../pulsar/broker/PulsarServiceMockSupport.java | 75 ---
.../apache/pulsar/broker/PulsarServiceTest.java | 59 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 98 +---
.../broker/admin/AdminApiSchemaWithAuthTest.java | 9 -
.../broker/admin/AdminApiSubscriptionTest.java | 72 ---
.../apache/pulsar/broker/admin/AdminApiTest.java | 54 --
.../apache/pulsar/broker/admin/NamespacesTest.java | 19 -
.../pulsar/broker/admin/TopicAutoCreationTest.java | 99 ----
.../broker/auth/AuthorizationWithAuthDataTest.java | 292 ----------
.../broker/auth/MockedPulsarServiceBaseTest.java | 20 -
.../delayed/InMemoryDeliveryTrackerTest.java | 49 +-
.../broker/intercept/BrokerInterceptorTest.java | 38 +-
.../broker/intercept/CounterBrokerInterceptor.java | 136 +----
.../intercept/MangedLedgerInterceptorImplTest.java | 139 +----
.../MultiBrokerLeaderElectionExpirationTest.java | 114 ----
.../loadbalance/MultiBrokerLeaderElectionTest.java | 38 +-
.../resourcegroup/ResourceGroupServiceTest.java | 8 -
.../broker/service/BacklogQuotaManagerTest.java | 200 ++-----
.../BatchMessageWithBatchIndexLevelTest.java | 4 -
.../broker/service/ConsumedLedgersTrimTest.java | 18 +-
.../broker/service/InactiveTopicDeleteTest.java | 41 +-
.../broker/service/MessageCumulativeAckTest.java | 9 +-
.../service}/MessageIdSerializationTest.java | 15 +-
.../pulsar/broker/service/MessageTTLTest.java | 30 +-
.../broker/service/NonPersistentTopicE2ETest.java | 58 +-
.../PersistentDispatcherFailoverConsumerTest.java | 36 +-
.../broker/service/PersistentFailoverE2ETest.java | 31 +-
.../broker/service/PersistentTopicE2ETest.java | 6 +-
.../pulsar/broker/service/PersistentTopicTest.java | 34 +-
.../broker/service/ReplicatorSubscriptionTest.java | 55 +-
.../pulsar/broker/service/ResendRequestTest.java | 3 +
.../broker/service/ServerCnxAuthorizationTest.java | 16 +-
.../persistent/PersistentSubscriptionTest.java | 4 +-
.../PersistentTopicStreamingDispatcherTest.java | 2 +-
.../service/persistent/PersistentTopicTest.java | 72 +--
.../broker/stats/ManagedCursorMetricsTest.java | 186 ++-----
.../pulsar/broker/transaction/TransactionTest.java | 52 +-
.../api/AuthenticatedProducerConsumerTest.java | 42 --
.../client/api/ConsumerBatchReceiveTest.java | 47 --
.../pulsar/client/api/ConsumerRedeliveryTest.java | 75 +--
.../pulsar/client/api/MultiTopicsConsumerTest.java | 34 +-
.../pulsar/client/api/PartitionCreationTest.java | 2 +-
.../api/PartitionedProducerConsumerTest.java | 2 -
.../client/api/SimpleProducerConsumerTest.java | 14 +-
.../client/api/v1/V1_ProducerConsumerTest.java | 15 +-
.../client/impl/ConsumerAckResponseTest.java | 99 ++++
.../apache/pulsar/client/impl/ConsumerAckTest.java | 256 ---------
.../pulsar/client/impl/NegativeAcksTest.java | 137 +----
.../client/impl/PatternTopicsConsumerImplTest.java | 10 +-
.../client/impl/ProducerMemoryLimitTest.java | 27 +-
.../client/impl/TransactionEndToEndTest.java | 109 +---
.../worker/PulsarFunctionLocalRunTest.java | 3 +-
.../functions/worker/PulsarFunctionTlsTest.java | 9 +-
.../apache/pulsar/io/PulsarFunctionTlsTest.java | 4 +-
.../java/org/apache/pulsar/schema/SchemaTest.java | 2 +-
.../SchemaCompatibilityCheckTest.java | 27 -
.../policies/data/InactiveTopicDeleteMode.java | 2 +-
.../pulsar/client/admin/internal/WorkerImpl.java | 4 +-
.../java/org/apache/pulsar/client/api/Schema.java | 6 +-
.../pulsar/client/api/transaction/Transaction.java | 57 --
.../PulsarClientImplementationBinding.java | 2 +
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.cc | 26 +-
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.h | 1 -
pulsar-client-cpp/python/pulsar/__init__.py | 13 +-
pulsar-client-cpp/python/pulsar_test.py | 31 --
pulsar-client-cpp/python/src/config.cc | 65 ++-
pulsar-client-cpp/python/src/utils.h | 20 -
pulsar-client-cpp/tests/ClientTest.cc | 11 +-
pulsar-client-cpp/tests/ConsumerTest.cc | 71 ---
pulsar-client-cpp/tests/WaitUtils.h | 43 --
.../pulsar/client/cli/PulsarClientToolTest.java | 22 -
.../pulsar/admin/cli/CmdPersistentTopics.java | 2 +-
.../org/apache/pulsar/client/cli/CmdProduce.java | 8 +-
.../client/impl/BatchMessageContainerImpl.java | 2 -
.../pulsar/client/impl/BatchMessageIdImpl.java | 6 -
.../client/impl/BinaryProtoLookupService.java | 37 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 15 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 30 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 23 +-
.../pulsar/client/impl/HttpLookupService.java | 16 +-
.../apache/pulsar/client/impl/MessageIdImpl.java | 10 +-
.../org/apache/pulsar/client/impl/MessageImpl.java | 2 +-
.../apache/pulsar/client/impl/MessagesImpl.java | 6 +-
.../client/impl/MultiTopicsConsumerImpl.java | 126 ++---
.../PersistentAcknowledgmentsGroupingTracker.java | 171 +++---
.../pulsar/client/impl/PulsarClientImpl.java | 179 +++---
.../PulsarClientImplementationBindingImpl.java | 4 +
.../client/impl/TypedMessageBuilderImpl.java | 98 ++--
.../impl/conf/ConsumerConfigurationData.java | 1 -
.../pulsar/client/impl/schema/AvroSchema.java | 4 +-
.../pulsar/client/impl/schema/BooleanSchema.java | 8 +-
.../pulsar/client/impl/schema/ByteBufSchema.java | 8 +-
.../client/impl/schema/ByteBufferSchema.java | 8 +-
.../pulsar/client/impl/schema/ByteSchema.java | 8 +-
.../pulsar/client/impl/schema/BytesSchema.java | 8 +-
.../pulsar/client/impl/schema/DateSchema.java | 8 +-
.../pulsar/client/impl/schema/DoubleSchema.java | 8 +-
.../pulsar/client/impl/schema/FloatSchema.java | 8 +-
.../pulsar/client/impl/schema/InstantSchema.java | 8 +-
.../pulsar/client/impl/schema/IntSchema.java | 8 +-
.../pulsar/client/impl/schema/JSONSchema.java | 11 +-
.../pulsar/client/impl/schema/LocalDateSchema.java | 8 +-
.../client/impl/schema/LocalDateTimeSchema.java | 8 +-
.../pulsar/client/impl/schema/LocalTimeSchema.java | 8 +-
.../pulsar/client/impl/schema/LongSchema.java | 8 +-
.../pulsar/client/impl/schema/ShortSchema.java | 8 +-
.../pulsar/client/impl/schema/StringSchema.java | 19 +-
.../pulsar/client/impl/schema/TimeSchema.java | 8 +-
.../pulsar/client/impl/schema/TimestampSchema.java | 8 +-
.../client/impl/transaction/TransactionImpl.java | 17 +-
.../pulsar/client/util/ExecutorProvider.java | 10 +-
.../client/util/ScheduledExecutorProvider.java | 36 --
.../apache/pulsar/client/impl/ClientCnxTest.java | 109 ----
.../client/impl/ConsumerBuilderImplTest.java | 202 -------
.../pulsar/client/impl/LastCumulativeAckTest.java | 20 -
.../client/impl/MultiTopicsConsumerImplTest.java | 2 +-
.../pulsar/client/impl/PulsarClientImplTest.java | 42 --
.../pulsar/client/impl/schema/AvroSchemaTest.java | 21 -
.../client/impl/schema/KeyValueSchemaInfoTest.java | 10 +-
.../client/impl/schema/StringSchemaTest.java | 20 +-
.../pulsar/client/impl/schema/SchemaInfoImpl.java | 34 +-
.../common/intercept/BrokerEntryMetadataUtils.java | 27 +-
.../intercept/ManagedLedgerPayloadProcessor.java | 62 ---
.../apache/pulsar/common/protocol/Commands.java | 4 -
.../pulsar/common/protocol/schema/SchemaHash.java | 25 +-
.../pulsar/common/util/netty/DnsResolverUtil.java | 8 +-
.../pulsar/common/compression/CommandsTest.java | 41 +-
.../pulsar/common/util/netty/DnsResolverTest.java | 41 --
.../functions/runtime/JavaInstanceStarter.java | 84 +--
.../functions/worker/WorkerStatsManager.java | 3 +-
pulsar-io/dynamodb/pom.xml | 1 +
.../io/elasticsearch/ElasticSearchClientTests.java | 68 +--
pulsar-io/kinesis/pom.xml | 1 +
.../apache/pulsar/metadata/api/MetadataCache.java | 7 -
.../pulsar/metadata/api/MetadataCacheConfig.java | 50 --
.../apache/pulsar/metadata/api/MetadataStore.java | 57 +-
.../metadata/cache/impl/MetadataCacheImpl.java | 49 +-
.../coordination/impl/LeaderElectionImpl.java | 28 +-
.../metadata/impl/AbstractMetadataStore.java | 18 +-
.../metadata/impl/FaultInjectionMetadataStore.java | 13 +-
.../apache/pulsar/metadata/MetadataCacheTest.java | 53 +-
.../server/ProxyWithJwtAuthorizationTest.java | 22 -
pulsar-sql/presto-distribution/LICENSE | 6 +-
pulsar-sql/presto-distribution/pom.xml | 4 +
.../pulsar/sql/presto/TestPulsarConnector.java | 4 +-
.../pulsar/testclient/DefaultMessageFormatter.java | 12 +-
.../pulsar/testclient/PerformanceConsumer.java | 6 -
.../pulsar/testclient/PerformanceReader.java | 11 +-
.../testclient/TestDefaultMessageFormatter.java | 8 +-
site2/docs/cookbooks-tiered-storage.md | 2 +-
site2/docs/reference-metrics.md | 62 +--
site2/docs/tiered-storage-aws.md | 2 +-
.../cookbooks-tiered-storage.md | 2 +-
.../cookbooks-tiered-storage.md | 2 +-
.../version-2.10.0-deprecated/reference-metrics.md | 617 ---------------------
.../version-2.2.0/cookbooks-tiered-storage.md | 2 +-
.../version-2.4.0/cookbooks-tiered-storage.md | 2 +-
.../version-2.5.0/cookbooks-tiered-storage.md | 2 +-
.../version-2.6.0/cookbooks-tiered-storage.md | 2 +-
.../version-2.6.0/reference-metrics.md | 2 +-
.../version-2.6.1/cookbooks-tiered-storage.md | 2 +-
.../version-2.6.1/reference-metrics.md | 2 +-
.../version-2.6.2/cookbooks-tiered-storage.md | 2 +-
.../version-2.6.2/reference-metrics.md | 2 +-
.../version-2.6.3/cookbooks-tiered-storage.md | 2 +-
.../version-2.6.3/reference-metrics.md | 2 +-
.../version-2.6.4/cookbooks-tiered-storage.md | 2 +-
.../version-2.6.4/reference-metrics.md | 2 +-
.../version-2.7.0/cookbooks-tiered-storage.md | 2 +-
.../version-2.7.0/reference-metrics.md | 2 +-
.../version-2.7.0/tiered-storage-aws.md | 2 +-
.../version-2.7.1/cookbooks-tiered-storage.md | 2 +-
.../version-2.7.1/reference-metrics.md | 2 +-
.../version-2.7.1/tiered-storage-aws.md | 2 +-
.../version-2.7.2/cookbooks-tiered-storage.md | 2 +-
.../version-2.7.2/reference-metrics.md | 2 +-
.../version-2.7.2/tiered-storage-aws.md | 2 +-
.../version-2.7.3/cookbooks-tiered-storage.md | 2 +-
.../version-2.7.3/reference-metrics.md | 2 +-
.../version-2.7.3/tiered-storage-aws.md | 2 +-
.../version-2.7.4/cookbooks-tiered-storage.md | 297 ----------
.../version-2.7.4/reference-metrics.md | 479 ----------------
.../version-2.7.4/tiered-storage-aws.md | 280 ----------
.../version-2.8.0-deprecated/reference-metrics.md | 552 ------------------
.../version-2.8.0/cookbooks-tiered-storage.md | 2 +-
.../version-2.8.0/tiered-storage-aws.md | 2 +-
.../version-2.8.1-deprecated/reference-metrics.md | 555 ------------------
.../version-2.8.1/cookbooks-tiered-storage.md | 2 +-
.../version-2.8.1/tiered-storage-aws.md | 2 +-
.../version-2.8.2-deprecated/reference-metrics.md | 564 -------------------
.../version-2.8.2/cookbooks-tiered-storage.md | 2 +-
.../version-2.8.2/tiered-storage-aws.md | 2 +-
.../version-2.8.3-deprecated/reference-metrics.md | 564 -------------------
.../version-2.9.0-deprecated/reference-metrics.md | 556 -------------------
.../version-2.9.0/cookbooks-tiered-storage.md | 311 -----------
.../version-2.9.0/tiered-storage-aws.md | 280 ----------
.../version-2.9.1-deprecated/reference-metrics.md | 556 -------------------
.../version-2.9.1/cookbooks-tiered-storage.md | 311 -----------
.../version-2.9.1/tiered-storage-aws.md | 280 ----------
.../version-2.9.2-deprecated/reference-metrics.md | 556 -------------------
.../bookkeeper/client/PulsarMockLedgerHandle.java | 6 +-
.../java/org/apache/zookeeper/MockZooKeeper.java | 161 +++---
.../pulsar/tests/integration/cli/PerfToolTest.java | 109 ----
.../integration/src/test/resources/pulsar-cli.xml | 1 -
.../impl/BlockAwareSegmentInputStreamImpl.java | 2 +-
.../impl/BlockAwareSegmentInputStreamTest.java | 15 -
.../offload/jcloud/impl/MockManagedLedger.java | 7 -
296 files changed, 2105 insertions(+), 14259 deletions(-)
rename managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/{cache
=> }/EntryCache.java (96%)
rename managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/{cache
=> }/EntryCacheDefaultEvictionPolicy.java (96%)
rename managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/{cache
=> }/EntryCacheEvictionPolicy.java (96%)
rename
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/{cache/RangeEntryCacheImpl.java
=> EntryCacheImpl.java} (90%)
create mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCacheManager.java
delete mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/EntryCacheDisabled.java
delete mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/EntryCacheManager.java
delete mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/RangeEntryCacheManagerImpl.java
delete mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/package-info.java
delete mode 100644
pulsar-broker-common/src/test/java/org/apache/pulsar/broker/web/plugin/servlet/AdditionalServletsTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/MultiBrokerTestZKBaseTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/PulsarServiceMockSupport.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSubscriptionTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/AuthorizationWithAuthDataTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/MultiBrokerLeaderElectionExpirationTest.java
rename {pulsar-client/src/test/java/org/apache/pulsar/client/impl =>
pulsar-broker/src/test/java/org/apache/pulsar/broker/service}/MessageIdSerializationTest.java
(75%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConsumerAckResponseTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConsumerAckTest.java
delete mode 100644 pulsar-client-cpp/tests/WaitUtils.h
delete mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/util/ScheduledExecutorProvider.java
delete mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/intercept/ManagedLedgerPayloadProcessor.java
delete mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/util/netty/DnsResolverTest.java
delete mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataCacheConfig.java
delete mode 100644
site2/website/versioned_docs/version-2.10.0-deprecated/reference-metrics.md
delete mode 100644
site2/website/versioned_docs/version-2.7.4/cookbooks-tiered-storage.md
delete mode 100644
site2/website/versioned_docs/version-2.7.4/reference-metrics.md
delete mode 100644
site2/website/versioned_docs/version-2.7.4/tiered-storage-aws.md
delete mode 100644
site2/website/versioned_docs/version-2.8.0-deprecated/reference-metrics.md
delete mode 100644
site2/website/versioned_docs/version-2.8.1-deprecated/reference-metrics.md
delete mode 100644
site2/website/versioned_docs/version-2.8.2-deprecated/reference-metrics.md
delete mode 100644
site2/website/versioned_docs/version-2.8.3-deprecated/reference-metrics.md
delete mode 100644
site2/website/versioned_docs/version-2.9.0-deprecated/reference-metrics.md
delete mode 100644
site2/website/versioned_docs/version-2.9.0/cookbooks-tiered-storage.md
delete mode 100644
site2/website/versioned_docs/version-2.9.0/tiered-storage-aws.md
delete mode 100644
site2/website/versioned_docs/version-2.9.1-deprecated/reference-metrics.md
delete mode 100644
site2/website/versioned_docs/version-2.9.1/cookbooks-tiered-storage.md
delete mode 100644
site2/website/versioned_docs/version-2.9.1/tiered-storage-aws.md
delete mode 100644
site2/website/versioned_docs/version-2.9.2-deprecated/reference-metrics.md
delete mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/PerfToolTest.java
