This is an automated email from the ASF dual-hosted git repository.
xyz pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 5a9912b67b4 Fix checkstyle issue
new 2107ff02a4b [improve][build] replace org.apache.commons.lang to
org.apache.commons.lang3 (#24473)
new 22ff023e79f [improve][broker] Upgrade bookkeeper to
4.17.2/commons-configuration to 2.x/grpc to 1.72.0 and enable ZooKeeper client
to establish connection in read-only mode (#24468)
new 2e07576dfa1 [improve][ci] Fixes #23079: Checkstyle checks applied to
all test (#24492)
new 77172b35a9e [improve][build] Bump org.apache.commons:commons-lang3
from 3.17.0 to 3.18.0 (#24514)
new ac7e9d84bb9 [improve][test] Add test for concurrent processing of
pending read Entries (#24519)
new 405e51abb83 [fix][proxy] Fix default value of connectionMaxIdleSeconds
in Pulsar Proxy (#24529)
new 1c1bf66b453 [fix][client] Fix issue in auto releasing of idle
connection with topics pattern consumer (#24528)
new 7ec5f1cc71b [improve][misc] Optimize topic list hashing so that
potentially large String allocation is avoided (#24525)
The 8 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:
.../pulsar/client/TlsProducerConsumerBase.java | 1 -
.../pulsar/client/TlsProducerConsumerTest.java | 18 +-
buildtools/pom.xml | 2 +-
.../src/main/resources/pulsar/checkstyle.xml | 7 +
.../src/main/resources/pulsar/suppressions.xml | 10 +-
.../BetweenTestClassesListenerAdapterTest.java | 12 +-
.../pulsar/tests/TestRetrySupportSuccessTest.java | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 107 ++--
distribution/shell/src/assemble/LICENSE.bin.txt | 13 +-
.../mledger/MetadataCompressionConfig.java | 2 +-
.../mledger/impl/EntryCacheManagerTest.java | 6 +-
.../bookkeeper/mledger/impl/EntryCacheTest.java | 1 -
.../impl/InflightReadsLimiterIntegrationTest.java | 4 +-
.../mledger/impl/ManagedCursorConcurrencyTest.java | 40 +-
.../mledger/impl/ManagedCursorContainerTest.java | 18 +-
...ManagedCursorIndividualDeletedMessagesTest.java | 1 -
.../impl/ManagedCursorInfoMetadataTest.java | 2 +-
.../mledger/impl/ManagedCursorListAckTest.java | 3 -
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 195 +++---
.../mledger/impl/ManagedLedgerBkTest.java | 49 +-
.../impl/ManagedLedgerFactoryShutdownTest.java | 3 -
.../mledger/impl/ManagedLedgerFactoryTest.java | 3 +-
.../impl/ManagedLedgerInfoMetadataTest.java | 15 +-
.../mledger/impl/ManagedLedgerMBeanTest.java | 3 +-
.../impl/ManagedLedgerSingleBookieTest.java | 1 -
.../mledger/impl/ManagedLedgerTerminationTest.java | 1 -
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 89 +--
.../bookkeeper/mledger/impl/MetaStoreImplTest.java | 2 +-
.../mledger/impl/NonDurableCursorTest.java | 11 +-
.../impl/OffloadEvictUnusedLedgersTest.java | 2 +-
.../mledger/impl/OffloadLedgerDeleteTest.java | 12 +-
.../mledger/impl/OffloadPrefixReadTest.java | 60 +-
.../bookkeeper/mledger/impl/OffloadPrefixTest.java | 54 +-
.../bookkeeper/mledger/impl/PositionTest.java | 41 +-
.../mledger/impl/RangeSetWrapperTest.java | 42 +-
.../mledger/impl/ReadOnlyCursorTest.java | 68 +-
.../mledger/impl/ShadowManagedLedgerImplTest.java | 4 +-
.../impl/cache/PendingReadsManagerTest.java | 93 ++-
.../mledger/offload/OffloadUtilsTest.java | 6 +-
.../mledger/offload/OffloadersCacheTest.java | 4 +-
.../bookkeeper/mledger/util/CallbackMutexTest.java | 11 +-
.../bookkeeper/mledger/util/TestStatsBuckets.java | 5 +-
.../bookkeeper/test/MockedBookKeeperTestCase.java | 4 +-
pom.xml | 6 +-
.../oidc/AuthenticationProviderOpenID.java | 2 +-
...uthenticationProviderOpenIDIntegrationTest.java | 11 +-
.../oidc/AuthenticationProviderOpenIDTest.java | 3 +-
.../ProxySaslAuthenticationTest.java | 24 +-
.../authentication/SaslServerTokenSignerTest.java | 4 +-
.../rackawareness/BookieRackAffinityMapping.java | 2 +-
.../configuration/PulsarConfigurationLoader.java | 2 +-
.../BookieRackAffinityMappingTest.java | 101 +--
.../IsolatedBookieEnsemblePlacementPolicyTest.java | 99 +--
.../org/apache/pulsar/broker/BitRateUnitTest.java | 2 +-
.../AuthenticationProviderBasicTest.java | 3 +-
.../AuthenticationProviderTokenTest.java | 25 +-
.../OneStageAuthenticationStateTest.java | 10 +-
.../authorization/MockAuthorizationProvider.java | 2 +-
.../MultiRolesTokenAuthorizationProviderTest.java | 12 +-
.../broker/resources/LoadBalanceResourcesTest.java | 2 +-
.../broker/resources/TopicResourcesTest.java | 36 +-
.../stats/prometheus/PrometheusMetricsClient.java | 4 +-
.../PrometheusMetricsGeneratorUtilsTest.java | 2 +-
.../broker/validator/BindAddressValidatorTest.java | 3 +-
.../validator/MultipleListenerValidatorTest.java | 9 +-
.../pulsar/broker/web/GzipHandlerUtilTest.java | 3 +-
.../plugin/servlet/AdditionalServletUtilsTest.java | 13 +-
.../AdditionalServletWithClassLoaderTest.java | 5 +-
.../web/plugin/servlet/AdditionalServletsTest.java | 8 +-
.../web/plugin/servlet/MockAdditionalServlet.java | 1 -
.../PulsarConfigurationLoaderTest.java | 4 +-
.../jetty/tls/JettySslContextFactoryTest.java | 6 +-
.../JettySslContextFactoryWithKeyStoreTest.java | 50 +-
.../org/apache/pulsar/PulsarBrokerStarter.java | 2 +-
.../apache/pulsar/PulsarClusterMetadataSetup.java | 3 +-
.../pulsar/broker/ManagedLedgerClientFactory.java | 2 +-
.../pulsar/broker/admin/impl/BrokersBase.java | 2 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 2 +-
.../broker/admin/impl/SchemasResourceBase.java | 2 +-
.../metrics/PrometheusMetricsProvider.java | 4 +-
.../pulsar/zookeeper/LocalBookkeeperEnsemble.java | 2 +-
.../impl/MangedLedgerInterceptorImpl2Test.java | 2 +-
.../NonEntryCacheKeySharedSubscriptionV30Test.java | 14 +-
.../org/apache/pulsar/PulsarStandaloneTest.java | 1 -
.../broker/BookKeeperClientFactoryImplTest.java | 5 +-
.../pulsar/broker/BrokerAdditionalServletTest.java | 13 +-
.../org/apache/pulsar/broker/BrokerTestUtil.java | 15 +-
.../LedgerLostAndSkipNonRecoverableTest.java | 16 +-
.../broker/MockedBookKeeperClientFactory.java | 6 +-
.../apache/pulsar/broker/MultiBrokerBaseTest.java | 14 +
.../pulsar/broker/MultiBrokerTestZKBaseTest.java | 2 +-
.../apache/pulsar/broker/PulsarServiceTest.java | 12 +-
.../pulsar/broker/TimeAverageBrokerDataTest.java | 5 +-
.../pulsar/broker/TopicEventsListenerTest.java | 11 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 149 +++--
.../pulsar/broker/admin/AdminApiClusterTest.java | 2 +-
.../broker/admin/AdminApiDelayedDeliveryTest.java | 22 +-
.../admin/AdminApiDynamicConfigurationsTest.java | 11 +-
.../broker/admin/AdminApiGetLastMessageIdTest.java | 8 +-
.../broker/admin/AdminApiHealthCheckTest.java | 14 +-
.../admin/AdminApiMaxUnackedMessagesTest.java | 14 +-
.../broker/admin/AdminApiMultiBrokersTest.java | 4 +-
.../pulsar/broker/admin/AdminApiOffloadTest.java | 2 +-
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 12 +-
.../pulsar/broker/admin/AdminApiSchemaTest.java | 36 +-
.../AdminApiSchemaValidationEnforcedTest.java | 6 +-
.../broker/admin/AdminApiSchemaWithAuthTest.java | 10 +-
.../broker/admin/AdminApiSubscriptionTest.java | 28 +-
.../pulsar/broker/admin/AdminApiTenantTest.java | 7 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 120 ++--
.../pulsar/broker/admin/AdminApiTlsAuthTest.java | 10 +-
.../pulsar/broker/admin/AdminResourceTest.java | 1 -
.../apache/pulsar/broker/admin/AdminRestTest.java | 2 +-
.../org/apache/pulsar/broker/admin/AdminTest.java | 68 +-
.../pulsar/broker/admin/AdminTopicApiTest.java | 6 +-
.../admin/AnalyzeBacklogSubscriptionTest.java | 16 +-
.../org/apache/pulsar/broker/admin/AuthZTest.java | 16 +-
.../apache/pulsar/broker/admin/BookiesApiTest.java | 1 -
.../admin/BrokerEndpointsAuthorizationTest.java | 75 ++-
.../admin/ClusterEndpointsAuthorizationTest.java | 23 +-
.../broker/admin/CreateSubscriptionTest.java | 6 +-
.../broker/admin/GetPartitionMetadataTest.java | 10 +-
.../pulsar/broker/admin/MockServletContext.java | 2 -
.../pulsar/broker/admin/NamespaceAuthZTest.java | 258 +++++---
.../apache/pulsar/broker/admin/NamespacesTest.java | 167 +++--
.../pulsar/broker/admin/PersistentTopicsTest.java | 48 +-
.../pulsar/broker/admin/ResourceGroupsTest.java | 6 +-
.../admin/TenantEndpointsAuthorizationTest.java | 16 +-
.../apache/pulsar/broker/admin/TopicAuthZTest.java | 306 +++++----
.../pulsar/broker/admin/TopicAutoCreationTest.java | 4 +-
.../pulsar/broker/admin/TopicMessageTTLTest.java | 13 +-
.../broker/admin/TopicPoliciesAuthZTest.java | 14 +-
.../pulsar/broker/admin/TopicPoliciesTest.java | 687 +++++++++++++--------
.../admin/TopicPoliciesWithBrokerRestartTest.java | 4 +-
.../apache/pulsar/broker/admin/TopicsAuthTest.java | 12 +-
.../org/apache/pulsar/broker/admin/TopicsTest.java | 191 +++---
.../pulsar/broker/admin/TopicsWithoutTlsTest.java | 30 +-
.../admin/TransactionAndSchemaAuthZTest.java | 3 +-
...{V1_AdminApi2Test.java => V1AdminApi2Test.java} | 14 +-
.../{V1_AdminApiTest.java => V1AdminApiTest.java} | 46 +-
.../v3/AdminApiTransactionMultiBrokerTest.java | 5 +-
.../broker/admin/v3/AdminApiTransactionTest.java | 58 +-
.../pulsar/broker/admin/v3/PackagesApiTest.java | 16 +-
.../apache/pulsar/broker/auth/AuthLogsTest.java | 6 +-
.../broker/auth/AuthenticationServiceTest.java | 9 +-
.../pulsar/broker/auth/AuthorizationTest.java | 3 +-
.../broker/auth/AuthorizationWithAuthDataTest.java | 2 +-
.../MockAlwaysExpiredAuthenticationProvider.java | 7 +-
.../pulsar/broker/auth/MockAuthentication.java | 8 +-
.../auth/MockMultiStageAuthenticationProvider.java | 2 +-
.../auth/MockMultiStageAuthenticationState.java | 7 +-
.../auth/MockMutableAuthenticationProvider.java | 4 +-
.../auth/MockMutableAuthenticationState.java | 4 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 48 +-
.../apache/pulsar/broker/auth/PortForwarder.java | 2 +-
.../broker/auth/SameThreadOrderedSafeExecutor.java | 1 -
.../delayed/DelayedDeliveryTrackerFactoryTest.java | 4 +-
.../delayed/InMemoryDeliveryTrackerTest.java | 4 +-
.../broker/delayed/MockBucketSnapshotStorage.java | 2 +-
.../bucket/BucketDelayedDeliveryTrackerTest.java | 6 +-
.../delayed/bucket/DelayedIndexQueueTest.java | 4 +-
.../broker/intercept/BrokerInterceptorTest.java | 4 +-
.../intercept/BrokerInterceptorUtilsTest.java | 18 +-
.../BrokerInterceptorWithClassLoaderTest.java | 3 +-
.../broker/intercept/CounterBrokerInterceptor.java | 4 +-
.../intercept/ExceptionsBrokerInterceptorTest.java | 6 +-
.../ManagedLedgerInterceptorImplTest.java | 74 ++-
.../broker/intercept/MockBrokerInterceptor.java | 5 +-
.../loadbalance/AdvertisedListenersTest.java | 10 +-
.../AntiAffinityNamespaceGroupTest.java | 8 +-
.../loadbalance/BrokerVersionFilterTest.java | 6 +-
.../loadbalance/LeaderElectionServiceTest.java | 3 +-
.../broker/loadbalance/LoadBalancerTest.java | 46 +-
.../loadbalance/LoadBalancerTestingUtils.java | 5 +-
.../ModularLoadManagerStrategyTest.java | 39 +-
.../broker/loadbalance/SimpleBrokerStartTest.java | 6 +-
.../loadbalance/SimpleLoadManagerImplTest.java | 18 +-
.../AntiAffinityNamespaceGroupExtensionTest.java | 2 +-
.../ExtensibleLoadManagerImplBaseTest.java | 11 +-
.../extensions/ExtensibleLoadManagerImplTest.java | 76 ++-
...LoadManagerImplWithAdvertisedListenersTest.java | 4 +-
.../channel/ServiceUnitStateChannelTest.java | 2 +-
.../channel/ServiceUnitStateDataTest.java | 2 +-
.../extensions/data/BrokerLoadDataTest.java | 22 +-
.../extensions/data/BrokerLookupDataTest.java | 3 +-
.../extensions/filter/BrokerFilterTestBase.java | 2 -
.../filter/BrokerIsolationPoliciesFilterTest.java | 6 +-
.../filter/BrokerLoadManagerClassFilterTest.java | 7 +-
.../filter/BrokerMaxTopicCountFilterTest.java | 12 +-
.../extensions/filter/BrokerVersionFilterTest.java | 4 +-
.../extensions/manager/RedirectManagerTest.java | 15 +-
.../extensions/manager/SplitManagerTest.java | 2 +-
.../extensions/manager/UnloadManagerTest.java | 2 +-
.../extensions/models/TopKBundlesTest.java | 2 +-
.../reporter/BrokerLoadDataReporterTest.java | 10 +-
.../reporter/TopBundleLoadDataReporterTest.java | 14 +-
.../extensions/scheduler/SplitSchedulerTest.java | 2 +-
.../extensions/scheduler/TransferShedderTest.java | 92 +--
.../extensions/scheduler/UnloadSchedulerTest.java | 19 +-
.../extensions/store/LoadDataStoreTest.java | 9 +-
.../DefaultNamespaceBundleSplitStrategyTest.java | 4 +-
.../strategy/LeastResourceUsageWithWeightTest.java | 8 +-
.../broker/loadbalance/impl/AvgShedderTest.java | 22 +-
.../impl/BrokerLoadManagerClassFilterTest.java | 5 +-
.../loadbalance/impl/BundleSplitterTaskTest.java | 13 +-
.../impl/ModularLoadManagerImplTest.java | 75 ++-
.../loadbalance/impl/ThresholdShedderTest.java | 2 +-
.../loadbalance/impl/UniformLoadShedderTest.java | 17 +-
.../broker/lookup/http/HttpTopicLookupv2Test.java | 20 +-
.../broker/lookup/http/v2/TopicLookupTest.java | 6 +-
.../namespace/NamespaceCreateBundlesTest.java | 5 +-
...ts.java => NamespaceOwnershipListenerTest.java} | 18 +-
.../broker/namespace/NamespaceServiceTest.java | 80 ++-
.../broker/namespace/NamespaceUnloadingTest.java | 2 -
.../OwnerShipCacheForCurrentServerTest.java | 7 +-
.../OwnerShipForCurrentServerTestBase.java | 2 +-
.../broker/protocol/ProtocolHandlerUtilsTest.java | 1 -
.../ProtocolHandlerWithClassLoaderTest.java | 1 -
.../broker/protocol/ProtocolHandlersTest.java | 1 -
.../protocol/PulsarClientBasedHandlerTest.java | 8 +-
.../protocol/SimpleProtocolHandlerTestsBase.java | 38 +-
.../RGUsageMTAggrWaitForAllMsgsTest.java | 179 +++---
.../ResourceGroupConfigListenerTest.java | 9 +-
.../ResourceGroupRateLimiterTest.java | 7 +-
.../resourcegroup/ResourceGroupServiceTest.java | 33 +-
.../ResourceGroupUsageAggregationTest.java | 43 +-
.../ResourceUsageTransportManagerTest.java | 12 +-
.../broker/service/AbstractBaseDispatcherTest.java | 3 +-
.../broker/service/AdvertisedAddressTest.java | 17 +-
.../BacklogQuotaManagerConfigurationTest.java | 7 +-
.../broker/service/BacklogQuotaManagerTest.java | 83 ++-
.../pulsar/broker/service/BatchMessageTest.java | 95 ++-
.../BatchMessageWithBatchIndexLevelTest.java | 29 +-
.../pulsar/broker/service/BkEnsemblesTestBase.java | 10 +-
...emblesTests.java => BrokerBkEnsemblesTest.java} | 16 +-
.../broker/service/BrokerBookieIsolationTest.java | 30 +-
.../service/BrokerDispatchRateLimiterTest.java | 2 +-
.../broker/service/BrokerEntryMetadataE2ETest.java | 11 +-
...kerInternalClientConfigurationOverrideTest.java | 12 +-
.../BrokerServiceAutoSubscriptionCreationTest.java | 3 +-
.../BrokerServiceAutoTopicCreationTest.java | 14 +-
.../BrokerServiceBundlesCacheInvalidationTest.java | 2 +-
.../pulsar/broker/service/BrokerServiceTest.java | 61 +-
.../service/BrokerServiceThrottlingTest.java | 8 +-
.../pulsar/broker/service/BrokerTestBase.java | 6 +-
.../pulsar/broker/service/BusyWaitServiceTest.java | 5 +-
.../CanReconnectZKClientPulsarServiceBaseTest.java | 6 +-
.../broker/service/ClusterMigrationTest.java | 281 +++++----
...istentHashingStickyKeyConsumerSelectorTest.java | 54 +-
.../broker/service/ConsumedLedgersTrimTest.java | 4 +-
.../DeduplicationDisabledBrokerLevelTest.java | 4 +-
.../DispatchRateLimiterOverconsumingTest.java | 3 +-
.../broker/service/DistributedIdGeneratorTest.java | 17 +-
.../broker/service/EnableProxyProtocolTest.java | 9 +-
.../broker/service/ExclusiveProducerTest.java | 3 +-
...eoReplicationWithConfigurationSyncTestBase.java | 6 +-
...angeAutoSplitStickyKeyConsumerSelectorTest.java | 12 +-
.../broker/service/InactiveTopicDeleteTest.java | 50 +-
.../InmemoryTopicPoliciesServiceServiceTest.java | 3 +-
.../apache/pulsar/broker/service/KeyValueTest.java | 3 +-
.../broker/service/MessageCumulativeAckTest.java | 2 +-
.../pulsar/broker/service/MessageTTLTest.java | 3 +-
.../broker/service/NetworkErrorTestBase.java | 8 +-
.../broker/service/NonPersistentTopicE2ETest.java | 10 +-
.../service/OneWayReplicatorDeduplicationTest.java | 7 +-
.../broker/service/OneWayReplicatorTest.java | 6 +-
.../broker/service/OneWayReplicatorTestBase.java | 14 +-
...OneWayReplicatorUsingGlobalPartitionedTest.java | 24 +-
.../broker/service/OpportunisticStripingTest.java | 4 +-
.../pulsar/broker/service/PartitionKeyTest.java | 1 -
.../PersistentDispatcherFailoverConsumerTest.java | 23 +-
.../broker/service/PersistentFailoverE2ETest.java | 21 +-
.../service/PersistentMessageFinderTest.java | 36 +-
.../broker/service/PersistentQueueE2ETest.java | 14 +-
.../service/PersistentTopicConcurrentTest.java | 3 +-
.../broker/service/PersistentTopicE2ETest.java | 48 +-
.../PersistentTopicInitializeDelayTest.java | 23 +-
.../pulsar/broker/service/PersistentTopicTest.java | 10 +-
.../PublishRateLimiterOverconsumingTest.java | 6 +-
.../broker/service/PublishRateLimiterTest.java | 2 +-
.../pulsar/broker/service/RackAwareTest.java | 2 +-
.../broker/service/ReplicatedSubscriptionTest.java | 36 +-
.../ReplicatedSubscriptionWithTransactionTest.java | 2 +-
.../broker/service/ReplicatorGlobalNSTest.java | 5 +-
.../broker/service/ReplicatorRateLimiterTest.java | 20 +-
.../service/ReplicatorRemoveClusterTest.java | 2 +-
.../pulsar/broker/service/ReplicatorTest.java | 39 +-
.../pulsar/broker/service/ReplicatorTestBase.java | 30 +-
.../pulsar/broker/service/ReplicatorTlsTest.java | 2 +-
.../service/ReplicatorTopicPoliciesTest.java | 16 +-
.../pulsar/broker/service/ResendRequestTest.java | 6 +-
.../pulsar/broker/service/ServerCnxTest.java | 19 +-
.../pulsar/broker/service/StandaloneTest.java | 5 +-
.../pulsar/broker/service/SubscribeRateTest.java | 9 +-
.../SubscriptionConsumerCompatibilityTest.java | 8 +-
.../broker/service/SubscriptionSeekTest.java | 38 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 67 +-
.../service/TopicDispatchRateLimiterTest.java | 2 +-
.../apache/pulsar/broker/service/TopicGCTest.java | 64 +-
.../broker/service/TopicListServiceTest.java | 24 +-
.../broker/service/TopicListWatcherTest.java | 12 +-
.../pulsar/broker/service/TopicOwnerTest.java | 9 +-
.../service/TopicPoliciesServiceDisableTest.java | 4 +-
.../service/TopicPublishRateThrottleTest.java | 9 +-
.../broker/service/TopicTerminationTest.java | 3 +-
.../service/TransactionMarkerDeleteTest.java | 2 +-
.../TransactionMetadataStoreServiceTest.java | 8 +-
.../TransactionalReplicateSubscriptionTest.java | 23 +-
.../pulsar/broker/service/ZkSessionExpireTest.java | 3 +-
...ntStickyKeyDispatcherMultipleConsumersTest.java | 5 +-
.../nonpersistent/NonPersistentTopicTest.java | 13 +-
.../persistent/BucketDelayedDeliveryTest.java | 28 +-
.../broker/service/persistent/ChecksumTest.java | 8 +-
.../service/persistent/DelayedDeliveryTest.java | 33 +-
.../service/persistent/MessageDuplicationTest.java | 20 +-
.../MessageRedeliveryControllerTest.java | 3 +-
.../PartitionKeywordCompatibilityTest.java | 3 +-
...tcherMultipleConsumerMaxEntriesInBatchTest.java | 12 +-
...tentDispatcherMultipleConsumersClassicTest.java | 9 +-
.../PersistentDispatcherMultipleConsumersTest.java | 9 +-
...rsistentDispatcherSingleActiveConsumerTest.java | 6 +-
.../PersistentReplicatorInflightTaskTest.java | 1 -
...yKeyDispatcherMultipleConsumersClassicTest.java | 8 +-
...ntStickyKeyDispatcherMultipleConsumersTest.java | 54 +-
.../persistent/PersistentSubscriptionTest.java | 14 +-
.../service/persistent/PersistentTopicTest.java | 45 +-
.../ReplicatedSubscriptionSnapshotCacheTest.java | 3 +-
...ReplicatedSubscriptionsSnapshotBuilderTest.java | 2 +-
.../persistent/RescheduleReadHandlerTest.java | 3 +-
.../broker/service/persistent/ShadowTopicTest.java | 4 +-
.../service/persistent/TopicDuplicationTest.java | 61 +-
.../broker/service/plugin/EntryFilter2Test.java | 2 +-
.../service/plugin/EntryFilterProviderTest.java | 5 +-
.../broker/service/plugin/EntryFilterTest.java | 1 -
.../broker/service/plugin/FilterEntryTest.java | 18 +-
.../schema/BaseAvroSchemaCompatibilityTest.java | 60 +-
.../schema/BookkeeperSchemaStorageTest.java | 15 +-
.../broker/service/schema/ClientGetSchemaTest.java | 18 +-
.../schema/JsonSchemaCompatibilityCheckTest.java | 12 +-
.../KeyValueSchemaCompatibilityCheckTest.java | 267 +++++---
.../schema/PartitionedTopicsSchemaTest.java | 14 +-
...ProtobufNativeSchemaCompatibilityCheckTest.java | 14 +-
.../broker/service/schema/SchemaServiceTest.java | 32 +-
.../schema/validator/SchemaDataValidatorTest.java | 1 -
...RegistryServiceWithSchemaDataValidatorTest.java | 5 +-
.../broker/service/utils/ClientChannelHelper.java | 34 +-
.../stats/AuthenticatedConsumerStatsTest.java | 16 +-
.../stats/BookieClientsStatsGeneratorTest.java | 9 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 33 +-
.../broker/stats/LedgerOffloaderMetricsTest.java | 2 +-
.../broker/stats/ManagedCursorMetricsTest.java | 2 +-
.../broker/stats/MetadataStoreStatsTest.java | 3 +-
.../stats/OpenTelemetryMetadataStoreStatsTest.java | 7 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 84 ++-
.../pulsar/broker/stats/SubscriptionStatsTest.java | 15 +-
.../stats/TransactionBatchWriterMetricsTest.java | 27 +-
.../NamespaceEventsSystemTopicServiceTest.java | 1 -
.../systopic/PartitionedSystemTopicTest.java | 15 +-
.../testcontext/AbstractTestPulsarService.java | 3 +-
.../testcontext/MockEntryFilterProvider.java | 16 +-
.../broker/testcontext/NonClosingProxyHandler.java | 6 +-
.../broker/testcontext/PulsarTestContext.java | 13 +-
.../testinterceptor/BrokerTestInterceptor.java | 18 +-
.../apache/pulsar/broker/tools/BrokerToolTest.java | 2 +-
...thenticatedTransactionProducerConsumerTest.java | 18 +-
.../SegmentAbortedTxnProcessorTest.java | 25 +-
.../TopicTransactionBufferRecoverTest.java | 51 +-
.../broker/transaction/TransactionConsumeTest.java | 12 +-
.../broker/transaction/TransactionProduceTest.java | 9 +-
.../pulsar/broker/transaction/TransactionTest.java | 30 +-
.../broker/transaction/TransactionTestBase.java | 14 +-
.../buffer/InMemTransactionBufferReaderTest.java | 3 +-
.../buffer/TopicTransactionBufferTest.java | 15 +-
.../buffer/TransactionBufferClientTest.java | 7 +-
.../buffer/TransactionBufferHandlerImplTest.java | 20 +-
.../transaction/buffer/TransactionBufferTest.java | 5 +-
.../buffer/TransactionEntryImplTest.java | 1 -
.../buffer/TransactionLowWaterMarkTest.java | 49 +-
.../buffer/TransactionStablePositionTest.java | 34 +-
.../buffer/utils/TransactionBufferTestImpl.java | 3 +-
.../TransactionCoordinatorClientTest.java | 8 +-
.../TransactionMetaStoreAssignmentTest.java | 11 +-
.../coordinator/TransactionMetaStoreTestBase.java | 2 +-
.../pendingack/PendingAckInMemoryDeleteTest.java | 8 +-
.../pendingack/PendingAckPersistentTest.java | 6 +-
.../pendingack/impl/MLPendingAckStoreTest.java | 7 +-
.../recover/TransactionRecoverTrackerTest.java | 16 +-
.../broker/web/MaxRequestSizeFilterTest.java | 2 +-
.../broker/web/ProcessHandlerFilterTest.java | 2 +-
.../pulsar/broker/web/RestExceptionTest.java | 5 +-
.../broker/web/WebServiceOriginalClientIPTest.java | 3 +-
.../apache/pulsar/broker/web/WebServiceTest.java | 33 +-
.../AdditionalServletWithClassLoaderTest.java | 4 +-
.../broker/zookeeper/ClusterMetadataSetupTest.java | 12 +-
.../pulsar/broker/zookeeper/ZKReconnectTest.java | 4 +-
.../ZooKeeperSessionExpireRecoveryTest.java | 4 +-
.../api/AuthenticatedProducerConsumerTest.java | 16 +-
.../AuthenticationTlsHostnameVerificationTest.java | 16 +-
.../api/AuthorizationProducerConsumerTest.java | 30 +-
.../pulsar/client/api/BrokerServiceLookupTest.java | 10 +-
.../org/apache/pulsar/client/api/BytesKeyTest.java | 1 -
.../client/api/ClientDeduplicationFailureTest.java | 43 +-
.../apache/pulsar/client/api/ClientErrorsTest.java | 26 +-
.../pulsar/client/api/ConsumerAckListTest.java | 21 +-
.../client/api/ConsumerBatchReceiveTest.java | 30 +-
.../pulsar/client/api/ConsumerCleanupTest.java | 3 +-
.../pulsar/client/api/ConsumerRedeliveryTest.java | 16 +-
.../DeadLetterTopicDefaultMultiPartitionsTest.java | 54 +-
.../pulsar/client/api/DeadLetterTopicTest.java | 100 +--
.../client/api/DispatcherBlockConsumerTest.java | 6 +-
.../api/ExposeMessageRedeliveryCountTest.java | 7 +-
.../apache/pulsar/client/api/InterceptorsTest.java | 18 +-
...ySharedSubscriptionDisabledBrokerCacheTest.java | 2 +-
.../client/api/KeySharedSubscriptionTest.java | 87 +--
.../pulsar/client/api/LookupPropertiesTest.java | 8 +-
.../apache/pulsar/client/api/MemoryLimitTest.java | 10 +-
.../client/api/MessageDispatchThrottlingTest.java | 19 +-
.../client/api/MessageListenerExecutorTest.java | 6 +-
.../pulsar/client/api/MockBrokerService.java | 19 +-
.../pulsar/client/api/MockBrokerServiceHooks.java | 1 -
.../pulsar/client/api/MultiTopicsConsumerTest.java | 7 +-
.../client/api/MutualAuthenticationTest.java | 5 +-
.../client/api/NonDurableSubscriptionTest.java | 9 +-
.../pulsar/client/api/NonPersistentTopicTest.java | 25 +-
.../client/api/OrphanPersistentTopicTest.java | 7 +-
.../pulsar/client/api/PartitionCreationTest.java | 41 +-
.../api/PartitionedProducerConsumerTest.java | 71 ++-
.../client/api/PatternMultiTopicsConsumerTest.java | 3 +-
.../pulsar/client/api/ProducerCleanupTest.java | 5 +-
.../pulsar/client/api/ProducerCreationTest.java | 9 +-
.../pulsar/client/api/ProducerQueueSizeTest.java | 6 +-
.../pulsar/client/api/ProxyProtocolTest.java | 5 +-
...MultiListenersWithInternalListenerNameTest.java | 16 +-
.../apache/pulsar/client/api/RetryTopicTest.java | 42 +-
.../pulsar/client/api/ServiceUrlProviderTest.java | 14 +-
.../client/api/SimpleProducerConsumerStatTest.java | 25 +-
.../client/api/SimpleProducerConsumerTest.java | 339 ++++++----
.../apache/pulsar/client/api/SimpleSchemaTest.java | 86 ++-
.../api/SimpleTypedProducerConsumerTest.java | 26 +-
.../SubscriptionMessageDispatchThrottlingTest.java | 7 +-
.../api/SubscriptionPauseOnAckStatPersistTest.java | 8 +-
.../pulsar/client/api/TlsHostVerificationTest.java | 1 -
.../pulsar/client/api/TlsProducerConsumerBase.java | 5 +-
.../pulsar/client/api/TlsProducerConsumerTest.java | 18 +-
.../org/apache/pulsar/client/api/TlsSniTest.java | 4 +-
.../TokenAuthenticatedProducerConsumerTest.java | 30 +-
.../api/TokenExpirationProduceConsumerTest.java | 10 +-
...kenOauth2AuthenticatedProducerConsumerTest.java | 12 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 131 ++--
.../pulsar/client/api/UnloadSubscriptionTest.java | 6 +-
...nsumerBase.java => V1ProducerConsumerBase.java} | 4 +-
...nsumerTest.java => V1ProducerConsumerTest.java} | 106 ++--
.../client/impl/AdminApiKeyStoreTlsAuthTest.java | 5 +-
.../AutoCloseUselessClientConMultiPartTest.java | 22 +-
.../AutoCloseUselessClientConMultiTopicTest.java | 60 +-
.../impl/AutoCloseUselessClientConNoPartTest.java | 22 +-
.../impl/AutoCloseUselessClientConSupports.java | 62 +-
.../impl/AutoCloseUselessClientConTXTest.java | 14 +-
...eUselessClientConTopicsPatternConsumerTest.java | 107 ++++
.../impl/AutoScaledReceiverQueueSizeTest.java | 6 +-
.../impl/BatchMessageIdImplSerializationTest.java | 2 -
.../impl/BatchMessageIndexAckDisableTest.java | 11 +-
.../client/impl/BrokerClientIntegrationTest.java | 23 +-
.../apache/pulsar/client/impl/ClientCnxTest.java | 2 +-
.../client/impl/ClientWithSocks5ProxyTest.java | 12 +-
.../client/impl/CompactedOutBatchMessageTest.java | 15 +-
.../client/impl/CompactionReaderImplTest.java | 2 +-
.../pulsar/client/impl/ConnectionHandlerTest.java | 1 -
.../pulsar/client/impl/ConnectionPoolTest.java | 2 +-
.../apache/pulsar/client/impl/ConsumerAckTest.java | 1 -
.../pulsar/client/impl/ConsumerCloseTest.java | 3 +-
.../client/impl/ConsumerConfigurationTest.java | 1 -
.../impl/ConsumerDedupPermitsUpdateTest.java | 3 -
.../client/impl/ConsumerUnsubscribeTest.java | 4 +-
...ests.java => DispatchAccordingPermitsTest.java} | 5 +-
.../impl/HierarchyTopicAutoCreationTest.java | 4 +-
...eySharedSubscriptionMaxUnackedMessagesTest.java | 4 +-
...eyStoreTlsProducerConsumerTestWithAuthTest.java | 31 +-
...toreTlsProducerConsumerTestWithoutAuthTest.java | 18 +-
.../pulsar/client/impl/MessageChecksumTest.java | 4 +-
.../pulsar/client/impl/MessageChunkingTest.java | 9 +-
.../client/impl/MessagePublishThrottlingTest.java | 4 +-
.../pulsar/client/impl/MessageRedeliveryTest.java | 11 +-
.../pulsar/client/impl/MultiTopicsReaderTest.java | 11 +-
.../pulsar/client/impl/NegativeAcksTest.java | 32 +-
.../impl/PartialPartitionedProducerTest.java | 29 +-
.../impl/PatternTopicsConsumerImplAuthTest.java | 26 +-
.../client/impl/PatternTopicsConsumerImplTest.java | 43 +-
.../PerMessageUnAcknowledgedRedeliveryTest.java | 2 -
.../client/impl/ProduceWithMessageIdTest.java | 2 +-
.../pulsar/client/impl/ProducerCloseTest.java | 17 +-
.../client/impl/ProducerConsumerInternalTest.java | 3 +-
.../client/impl/ProducerEmptySchemaCacheTest.java | 8 +-
.../pulsar/client/impl/ProducerMemoryLeakTest.java | 6 +-
.../pulsar/client/impl/ProducerSemaphoreTest.java | 31 +-
.../PulsarClientConfigurationOverrideTest.java | 3 +-
.../client/impl/PulsarMultiHostClientTest.java | 3 +-
.../pulsar/client/impl/PulsarTestClient.java | 3 +-
.../impl/RawBatchMessageContainerImplTest.java | 4 +-
.../pulsar/client/impl/RawMessageSerDeserTest.java | 9 +-
.../apache/pulsar/client/impl/RawReaderTest.java | 39 +-
.../org/apache/pulsar/client/impl/ReaderTest.java | 21 +-
.../apache/pulsar/client/impl/RetryUtilTest.java | 16 +-
.../pulsar/client/impl/SchemaDeleteTest.java | 3 -
.../client/impl/SequenceIdWithErrorTest.java | 8 +-
.../apache/pulsar/client/impl/TableViewTest.java | 3 +-
.../pulsar/client/impl/TopicDoesNotExistsTest.java | 5 +-
.../pulsar/client/impl/TopicFromMessageTest.java | 3 +-
.../pulsar/client/impl/TopicsConsumerImplTest.java | 127 ++--
.../client/impl/TransactionClientConnectTest.java | 3 +-
.../client/impl/TransactionEndToEndTest.java | 53 +-
...ransactionEndToEndWithoutBatchIndexAckTest.java | 4 +-
.../impl/UnAcknowledgedMessagesTimeoutTest.java | 2 -
.../pulsar/client/impl/ZeroQueueSizeTest.java | 7 +-
.../processor/CustomBatchPayloadProcessor.java | 2 +-
.../processor/DefaultProcessorWithRefCnt.java | 5 +-
.../processor/MessagePayloadProcessorTest.java | 2 +-
...OrQpsEquallyDivideBundleSplitAlgorithmTest.java | 15 +-
.../naming/NamespaceBundleSplitAlgorithmTest.java | 19 +-
.../pulsar/common/naming/NamespaceBundleTest.java | 26 +-
.../pulsar/common/naming/NamespaceBundlesTest.java | 21 +-
...RangeEquallyDivideBundleSplitAlgorithmTest.java | 14 +-
.../common/naming/ServiceConfigurationTest.java | 54 +-
...SpecifiedPositionsBundleSplitAlgorithmTest.java | 14 +-
...CountEquallyDivideBundleSplitAlgorithmTest.java | 7 +-
.../common/protocol/ProducerBatchSendTest.java | 3 +-
.../pulsar/compaction/CompactedTopicImplTest.java | 20 +-
.../pulsar/compaction/CompactedTopicTest.java | 63 +-
.../pulsar/compaction/CompactionRetentionTest.java | 11 +-
.../apache/pulsar/compaction/CompactionTest.java | 101 +--
.../pulsar/compaction/CompactorMXBeanImplTest.java | 3 +-
.../apache/pulsar/compaction/CompactorTest.java | 5 +-
.../pulsar/compaction/CompactorToolTest.java | 2 +-
.../compaction/EventTimeOrderCompactorTest.java | 1 -
.../compaction/ServiceUnitStateCompactionTest.java | 140 +++--
.../pulsar/compaction/StrategicCompactionTest.java | 11 +-
.../compaction/TopicCompactionServiceTest.java | 3 +-
.../apache/pulsar/functions/worker/FileServer.java | 3 +-
.../worker/PulsarFunctionE2ESecurityTest.java | 35 +-
.../worker/PulsarFunctionLocalRunTest.java | 112 ++--
.../worker/PulsarFunctionMetadataStoreTest.java | 2 +-
.../worker/PulsarFunctionPublishTest.java | 42 +-
.../PulsarFunctionTestTemporaryDirectory.java | 2 +-
.../functions/worker/PulsarFunctionTlsTest.java | 16 +-
.../worker/PulsarWorkerAssignmentTest.java | 16 +-
.../functions/worker/TestPulsarFunctionUtils.java | 10 +-
.../apache/pulsar/io/AbstractPulsarE2ETest.java | 45 +-
.../apache/pulsar/io/PulsarBatchSourceE2ETest.java | 35 +-
.../apache/pulsar/io/PulsarFunctionAdminTest.java | 15 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 141 +++--
.../apache/pulsar/io/PulsarFunctionTlsTest.java | 12 +-
.../org/apache/pulsar/io/PulsarSinkE2ETest.java | 139 +++--
.../org/apache/pulsar/io/PulsarSourceE2ETest.java | 53 +-
.../java/org/apache/pulsar/io/SinkForTest.java | 1 -
.../java/org/apache/pulsar/schema/SchemaTest.java | 95 +--
.../SchemaCompatibilityCheckTest.java | 40 +-
...hemaTypeCompatibilityCheckOnTopicLevelTest.java | 3 +-
.../SchemaTypeCompatibilityCheckTest.java | 19 +-
.../pulsar/security/MockedPulsarStandalone.java | 12 +-
.../tls/ec/TlsWithECCertificateFileTest.java | 2 +-
.../security/tls/ec/TlsWithECKeyStoreTest.java | 8 +-
.../socks5/handler/CommandRequestHandler.java | 9 +-
.../stats/client/PulsarBrokerStatsClientTest.java | 1 -
.../ConcurrentBitmapSortedLongPairSetTest.java | 8 +-
.../pulsar/utils/SimpleTextOutputStreamTest.java | 7 +-
.../apache/pulsar/utils/StatsOutputStreamTest.java | 7 +-
.../utils/auth/tokens/TokensCliUtilsTest.java | 8 +-
.../proxy/ClientSideEncryptionWssProducer.java | 2 +-
.../websocket/proxy/CryptoKeyReaderForTest.java | 20 +-
.../proxy/MockAuthenticationProvider.java | 2 -
.../proxy/MockUnauthenticationProvider.java | 3 +-
.../websocket/proxy/ProxyAuthenticationTest.java | 21 +-
.../websocket/proxy/ProxyAuthorizationTest.java | 2 +-
.../proxy/ProxyEncryptionPublishConsumeTest.java | 20 +-
.../websocket/proxy/ProxyIdleTimeoutTest.java | 4 +-
.../pulsar/websocket/proxy/ProxyPingTest.java | 4 +-
.../websocket/proxy/ProxyPublishConsumeTest.java | 148 +++--
.../proxy/ProxyPublishConsumeTlsTest.java | 10 +-
.../proxy/ProxyPublishConsumeWithoutZKTest.java | 6 +-
.../websocket/proxy/WssClientSideEncryptUtils.java | 5 +-
...ionTest.java => V1ProxyAuthenticationTest.java} | 24 +-
.../zookeeper/LocalBookkeeperEnsembleTest.java | 1 -
.../pulsar/cli/converters/TimeConversionTest.java | 12 +-
.../admin/internal/PulsarAdminBuilderImplTest.java | 7 +-
.../client/admin/internal/PulsarAdminGzipTest.java | 2 +-
.../client/admin/internal/PulsarAdminImplTest.java | 5 +-
.../client/admin/internal/SinksImplTest.java | 6 +-
.../client/impl/auth/AuthenticationAthenzTest.java | 40 +-
.../apache/pulsar/admin/cli/CmdFunctionsTest.java | 12 +-
.../pulsar/admin/cli/PulsarAdminToolTest.java | 371 ++++++-----
.../apache/pulsar/admin/cli/utils/IOUtilsTest.java | 1 -
.../pulsar/client/cli/PulsarClientToolTest.java | 20 +-
.../pulsar/client/cli/PulsarClientToolWsTest.java | 14 +-
.../org/apache/pulsar/admin/cli/CmdFunctions.java | 6 +-
.../pulsar/admin/cli/CmdTopicPoliciesTest.java | 2 +-
.../pulsar/admin/cli/TestCmdFunctionWorker.java | 9 +-
.../apache/pulsar/admin/cli/TestCmdNamespaces.java | 10 +-
.../apache/pulsar/admin/cli/TestCmdPackages.java | 4 +-
.../org/apache/pulsar/admin/cli/TestCmdSchema.java | 1 -
.../org/apache/pulsar/admin/cli/TestCmdSinks.java | 52 +-
.../apache/pulsar/admin/cli/TestCmdSources.java | 100 +--
.../apache/pulsar/client/cli/TestCmdConsume.java | 1 -
.../apache/pulsar/client/cli/TestCmdProduce.java | 34 +-
.../org/apache/pulsar/client/cli/TestCmdRead.java | 1 -
.../org/apache/pulsar/shell/ConfigShellTest.java | 24 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 3 +
.../pulsar/client/impl/ClientCnxIdleState.java | 7 +-
.../pulsar/client/impl/ZeroQueueConsumerImpl.java | 2 +-
.../impl/auth/oauth2/AuthenticationOAuth2.java | 4 +-
.../pulsar/client/impl/auth/oauth2/FlowBase.java | 2 +-
.../pulsar/client/api/AuthenticationTest.java | 9 +-
.../client/api/ConsumerConfigurationTest.java | 8 +-
.../apache/pulsar/client/api/ConsumerIdTest.java | 7 +-
.../apache/pulsar/client/api/MessageIdTest.java | 1 -
.../pulsar/client/api/MessageRouterTest.java | 1 -
.../api/MultiplierRedeliveryBackoffTest.java | 4 +-
.../pulsar/client/examples/TransactionExample.java | 3 +-
.../impl/AcknowledgementsGroupingTrackerTest.java | 11 +-
.../client/impl/BatchMessageContainerImplTest.java | 10 +-
.../client/impl/BinaryProtoLookupServiceTest.java | 8 +-
.../apache/pulsar/client/impl/BuildersTest.java | 20 +-
.../pulsar/client/impl/ClientBuilderImplTest.java | 11 +-
.../pulsar/client/impl/ClientCnxIdleStateTest.java | 61 ++
.../impl/ClientCnxRequestTimeoutQueueTest.java | 18 +-
.../apache/pulsar/client/impl/ClientCnxTest.java | 23 +-
.../pulsar/client/impl/ClientTestFixtures.java | 6 +-
.../client/impl/ConsumerBuilderImplTest.java | 12 +-
.../pulsar/client/impl/ConsumerImplTest.java | 7 +-
.../client/impl/ControlledClusterFailoverTest.java | 5 +-
.../client/impl/DefaultCryptoKeyReaderTest.java | 86 ++-
.../pulsar/client/impl/MessageIdAdvUtilsTest.java | 2 +-
.../pulsar/client/impl/MessageIdCompareToTest.java | 3 +-
.../apache/pulsar/client/impl/MessageImplTest.java | 57 +-
.../client/impl/PartitionedProducerImplTest.java | 23 +-
.../impl/PatternMultiTopicsConsumerImplTest.java | 7 +-
.../client/impl/ProducerBuilderImplTest.java | 3 +-
.../pulsar/client/impl/ProducerImplTest.java | 5 +-
.../pulsar/client/impl/PulsarClientImplTest.java | 4 +-
.../client/impl/PulsarServiceNameResolverTest.java | 1 -
.../apache/pulsar/client/impl/ReaderImplTest.java | 6 +-
.../RoundRobinPartitionMessageRouterImplTest.java | 2 -
.../impl/SinglePartitionMessageRouterImplTest.java | 7 +-
.../client/impl/TableViewBuilderImplTest.java | 3 +-
.../impl/TableViewConfigurationDataTest.java | 3 +-
.../pulsar/client/impl/TableViewImplTest.java | 10 +-
.../pulsar/client/impl/TopicListWatcherTest.java | 22 +-
.../pulsar/client/impl/TopicMessageIdImplTest.java | 1 -
.../pulsar/client/impl/TopicMetadataImplTest.java | 1 -
.../pulsar/client/impl/TransactionBuilderTest.java | 4 +-
.../impl/TransactionMetaStoreHandlerTest.java | 1 -
.../client/impl/TypedMessageBuilderImplTest.java | 140 +++--
.../client/impl/UnAckedMessageTrackerTest.java | 7 +-
.../client/impl/auth/AuthenticationTlsTest.java | 8 +-
.../client/impl/auth/AuthenticationTokenTest.java | 12 +-
.../client/impl/auth/MockAuthentication.java | 7 +-
.../MockEncodedAuthenticationParameterSupport.java | 12 +-
.../impl/auth/oauth2/AuthenticationOAuth2Test.java | 2 -
.../impl/auth/oauth2/protocol/TokenClientTest.java | 6 +-
.../impl/conf/ConfigurationDataUtilsTest.java | 21 +-
.../impl/conf/ConsumerConfigurationDataTest.java | 2 -
...efaultCryptoKeyReaderConfigurationDataTest.java | 11 +-
.../pulsar/client/impl/schema/AvroSchemaTest.java | 52 +-
.../pulsar/client/impl/schema/BytesSchemaTest.java | 3 +-
.../pulsar/client/impl/schema/DateSchemaTest.java | 7 +-
.../client/impl/schema/DefaultSchemasTest.java | 2 -
.../client/impl/schema/DoubleSchemaTest.java | 2 +-
.../pulsar/client/impl/schema/FloatSchemaTest.java | 2 +-
.../client/impl/schema/InstantSchemaTest.java | 4 +-
.../pulsar/client/impl/schema/IntSchemaTest.java | 2 +-
.../pulsar/client/impl/schema/JSONSchemaTest.java | 64 +-
.../client/impl/schema/KeyValueSchemaInfoTest.java | 9 +-
.../client/impl/schema/KeyValueSchemaTest.java | 76 ++-
.../client/impl/schema/LocalDateSchemaTest.java | 6 +-
.../impl/schema/LocalDateTimeSchemaTest.java | 4 +-
.../client/impl/schema/LocalTimeSchemaTest.java | 8 +-
.../pulsar/client/impl/schema/LongSchemaTest.java | 4 +-
.../client/impl/schema/PrimitiveSchemaTest.java | 33 +-
.../impl/schema/ProtobufNativeSchemaTest.java | 62 +-
.../impl/schema/ProtobufNativeSchemaUtilsTest.java | 3 +-
.../client/impl/schema/ProtobufSchemaTest.java | 91 +--
.../client/impl/schema/SchemaBuilderTest.java | 26 +-
.../pulsar/client/impl/schema/SchemaInfoTest.java | 8 +-
.../pulsar/client/impl/schema/SchemaTestUtils.java | 101 +--
.../pulsar/client/impl/schema/ShortSchemaTest.java | 4 +-
.../client/impl/schema/StringSchemaTest.java | 6 +-
.../schema/SupportVersioningAvroSchemaTest.java | 13 +-
.../SupportVersioningKeyValueSchemaTest.java | 11 +-
.../pulsar/client/impl/schema/TimeSchemaTest.java | 7 +-
.../client/impl/schema/TimestampSchemaTest.java | 7 +-
.../schema/generic/AbstractGenericSchemaTest.java | 28 +-
.../impl/schema/generic/GenericAvroReaderTest.java | 4 +-
.../impl/schema/generic/GenericAvroRecordTest.java | 4 +-
.../impl/schema/generic/GenericAvroSchemaTest.java | 10 +-
.../impl/schema/generic/GenericJsonRecordTest.java | 12 +-
.../generic/GenericProtobufNativeReaderTest.java | 26 +-
.../generic/GenericProtobufNativeSchemaTest.java | 9 +-
.../impl/schema/generic/GenericSchemaImplTest.java | 5 +-
.../impl/schema/generic/GenericSchemaTest.java | 27 +-
.../MultiVersionSchemaInfoProviderTest.java | 5 +-
.../client/tutorial/ContinuousAsyncProducer.java | 1 -
.../pulsar/client/tutorial/ContinuousProducer.java | 1 -
.../client/tutorial/SampleAsyncProducer.java | 4 +-
.../tutorial/SampleAsyncProducerWithSchema.java | 3 +-
.../pulsar/client/tutorial/SampleConsumer.java | 3 +-
.../client/tutorial/SampleConsumerListener.java | 4 +-
.../client/tutorial/SampleCryptoConsumer.java | 4 +-
.../client/tutorial/SampleCryptoProducer.java | 4 +-
.../pulsar/client/tutorial/SampleProducer.java | 1 -
.../apache/pulsar/client/util/ObjectCacheTest.java | 2 -
.../apache/pulsar/common/schema/KeyValueTest.java | 15 +-
.../org/apache/pulsar/common/functions/Utils.java | 2 +-
.../org/apache/pulsar/common/net/ServiceURI.java | 2 +-
.../org/apache/pulsar/common/topics/TopicList.java | 20 +-
.../ConcurrentOpenLongPairRangeSet.java | 2 +-
.../util/collections/OpenLongPairRangeSet.java | 2 +-
.../apache/pulsar/AddMissingPatchVersionTest.java | 1 -
.../pulsar/common/api/raw/RawMessageImplTest.java | 6 +-
.../pulsar/common/compression/CommandsTest.java | 2 +-
.../compression/CompressionCodecZstdJNI.java | 3 -
.../CompressorCodecBackwardCompatTest.java | 11 +-
.../common/compression/CompressorCodecTest.java | 48 +-
.../common/compression/Crc32cChecksumTest.java | 5 +-
.../common/io/BatchSourceConfigParseTest.java | 48 +-
.../pulsar/common/lookup/data/LookupDataTest.java | 5 +-
.../{MetadataTests.java => MetadataTest.java} | 2 +-
.../pulsar/common/naming/NamespaceNameTest.java | 1 -
.../apache/pulsar/common/naming/TopicNameTest.java | 3 +-
.../apache/pulsar/common/nar/NarUnpackerTest.java | 3 +-
.../apache/pulsar/common/net/ServiceURITest.java | 11 +-
.../policies/data/AutoFailoverPolicyDataTest.java | 2 -
.../policies/data/AutoFailoverPolicyTypeTest.java | 2 -
.../data/AutoTopicCreationOverrideTest.java | 5 +-
.../common/policies/data/ClusterDataImplTest.java | 4 +-
.../common/policies/data/ClusterDataTest.java | 1 -
.../common/policies/data/ConsumerStatsTest.java | 17 +-
.../data/EnsemblePlacementPolicyConfigTest.java | 3 +-
.../common/policies/data/LocalPolicesTest.java | 22 +-
.../policies/data/NamespaceIsolationDataTest.java | 2 -
.../data/NamespaceOwnershipStatusTest.java | 10 +-
.../NonPersistentPartitionedTopicStatsTest.java | 8 +-
.../common/policies/data/OffloadPoliciesTest.java | 13 +-
.../pulsar/common/policies/data/OldPolicies.java | 24 +-
.../policies/data/PartitionedTopicStatsTest.java | 1 -
.../policies/data/PersistencePoliciesTest.java | 1 -
.../data/PersistentOfflineTopicStatsTest.java | 1 -
.../policies/data/PersistentTopicStatsTest.java | 8 +-
.../common/policies/data/PoliciesDataTest.java | 27 +-
.../common/policies/data/PublisherStatsTest.java | 21 +-
.../common/policies/data/RetentionPolicesTest.java | 1 -
.../impl/AutoFailoverPolicyFactoryTest.java | 1 -
.../policies/impl/MinAvailablePolicyTest.java | 1 -
.../impl/NamespaceIsolationPoliciesTest.java | 13 +-
.../impl/NamespaceIsolationPolicyImplTest.java | 11 +-
...ommandUtilsTests.java => CommandUtilsTest.java} | 32 +-
.../apache/pulsar/common/protocol/MarkersTest.java | 3 -
.../common/stats/CacheMetricsCollectorTest.java | 2 +-
.../stats/JvmDefaultGCMetricsLoggerTest.java | 5 +-
.../apache/pulsar/common/topics/TopicListTest.java | 37 +-
.../org/apache/pulsar/common/util/BackoffTest.java | 5 +-
.../common/util/DefaultPulsarSslFactoryTest.java | 18 +-
.../apache/pulsar/common/util/FieldParserTest.java | 4 +-
.../common/util/FileModifiedTimeUpdaterTest.java | 2 -
.../apache/pulsar/common/util/FutureUtilTest.java | 16 +-
.../apache/pulsar/common/util/PortManagerTest.java | 3 +-
.../apache/pulsar/common/util/ReflectionsTest.java | 30 +-
.../pulsar/common/util/RelativeTimeUtilTest.java | 2 -
.../pulsar/common/util/URIPreconditionsTest.java | 5 +-
.../collections/ConcurrentLongHashMapTest.java | 31 +-
.../ConcurrentLongLongPairHashMapTest.java | 2 -
.../collections/ConcurrentLongPairSetTest.java | 49 +-
.../util/collections/DefaultRangeSetTest.java | 15 +-
.../common/util/collections/FieldParserTest.java | 2 -
.../GrowableArrayBlockingQueueTest.java | 5 +-
.../GrowablePriorityLongPairQueueTest.java | 37 +-
.../util/collections/OpenLongPairRangeSetTest.java | 64 +-
.../collections/TripleLongPriorityQueueTest.java | 25 +-
.../common/util/netty/ChannelFuturesTest.java | 3 -
.../pulsar/common/util/netty/SslContextTest.java | 40 +-
.../pulsar/exception/PulsarExceptionTest.java | 3 +-
.../data/loadbalancer/LocalBrokerDataTest.java | 41 +-
.../config/validation/ConfigValidationTest.java | 10 +-
.../config/validation/ValidatorImplsTest.java | 9 +-
.../functions/instance/ProducerBuilderFactory.java | 2 +-
.../functions/instance/InstanceUtilsTest.java | 6 +-
.../instance/JavaInstanceRunnableTest.java | 2 +-
.../functions/instance/JavaInstanceTest.java | 40 +-
.../instance/ProducerBuilderFactoryTest.java | 12 +-
.../instance/state/BKStateStoreImplTest.java | 12 +-
.../pulsar/functions/sink/PulsarSinkTest.java | 16 +-
.../functions/source/PulsarFunctionRecordTest.java | 1 -
.../pulsar/functions/source/TopicSchemaTest.java | 16 +-
.../source/batch/BatchSourceExecutorTest.java | 5 +-
.../windowing/WaterMarkEventGeneratorTest.java | 2 +-
.../windowing/WindowFunctionExecutorTest.java | 8 +-
.../functions/windowing/WindowManagerTest.java | 34 +-
.../functions/instance/JavaInstanceDepsTest.java | 14 +-
.../ClearTextFunctionTokenAuthProviderTest.java | 12 +-
.../KubernetesSecretsTokenAuthProviderTest.java | 77 ++-
...ernetesServiceAccountTokenAuthProviderTest.java | 24 +-
.../pulsar/functions/config/TestWorkerConfig.java | 8 +-
.../pulsar/functions/runtime/RuntimeUtilsTest.java | 13 +-
.../BasicKubernetesManifestCustomizerTest.java | 21 +-
.../kubernetes/KubernetesRuntimeFactoryTest.java | 198 +++---
.../runtime/kubernetes/KubernetesRuntimeTest.java | 334 ++++++----
.../runtime/process/ProcessRuntimeTest.java | 37 +-
.../runtime/thread/ThreadRuntimeFactoryTest.java | 42 +-
.../worker/WorkerApiV2ResourceConfigTest.java | 15 +-
.../ClearTextSecretsProviderTest.java | 1 -
.../KubernetesSecretsProviderConfiguratorTest.java | 12 +-
.../apache/pulsar/functions/utils/CryptoUtils.java | 2 +-
.../pulsar/functions/utils/SinkConfigUtils.java | 2 +-
.../apache/pulsar/functions/utils/ActionsTest.java | 7 +-
.../pulsar/functions/utils/ExceptionsTest.java | 10 +-
.../pulsar/functions/utils/FunctionCommonTest.java | 9 +-
.../functions/utils/FunctionConfigUtilsTest.java | 60 +-
.../functions/utils/FunctionMetaDataUtilsTest.java | 3 +-
.../functions/utils/SinkConfigUtilsTest.java | 69 ++-
.../functions/utils/SourceConfigUtilsTest.java | 51 +-
.../functions/utils/WindowConfigUtilsTest.java | 5 +-
.../pulsar/functions/worker/FunctionActioner.java | 2 +-
.../functions/worker/rest/api/SinksImpl.java | 2 +-
.../functions/worker/rest/api/SourcesImpl.java | 2 +-
.../worker/ClusterServiceCoordinatorTest.java | 3 +-
.../worker/FunctionMetaDataManagerTest.java | 10 +-
.../worker/FunctionRuntimeManagerTest.java | 39 +-
.../functions/worker/SchedulerManagerTest.java | 62 +-
.../functions/worker/dlog/DLInputStreamTest.java | 5 +-
.../worker/rest/api/FunctionsImplTest.java | 12 +-
.../api/PulsarFunctionTestTemporaryDirectory.java | 2 +-
.../rest/api/v2/FunctionApiV2ResourceTest.java | 41 +-
.../api/v3/AbstractFunctionApiResourceTest.java | 518 ++++++++--------
.../rest/api/v3/AbstractFunctionsResourceTest.java | 16 +-
.../rest/api/v3/FunctionApiV3ResourceTest.java | 102 +--
.../worker/rest/api/v3/SinkApiV3ResourceTest.java | 296 ++++-----
.../rest/api/v3/SourceApiV3ResourceTest.java | 258 ++++----
.../io/alluxio/sink/AlluxioSinkConfigTest.java | 10 +-
.../pulsar/io/alluxio/sink/AlluxioSinkTest.java | 20 +-
.../io/azuredataexplorer/ADXSinkConfigTest.java | 10 +-
.../io/azuredataexplorer/ADXSinkE2ETest.java | 22 +-
.../batchdatagenerator/BatchDataGeneratorExec.java | 7 +-
.../apache/pulsar/io/common/IOConfigUtilsTest.java | 38 +-
.../apache/pulsar/io/core/BatchPushSourceTest.java | 5 +-
.../java/org/apache/pulsar/io/core/SinkTest.java | 10 +-
.../java/org/apache/pulsar/io/core/SourceTest.java | 10 +-
.../io/debezium/PulsarDatabaseHistoryTest.java | 31 +-
...figTests.java => DynamoDBSourceConfigTest.java} | 49 +-
...chAuthTests.java => ElasticSearchAuthTest.java} | 4 +-
...archBWCTests.java => ElasticSearchBWCTest.java} | 11 +-
...lTests.java => ElasticSearchClientSslTest.java} | 88 ++-
...ientTests.java => ElasticSearchClientTest.java} | 22 +-
...nfigTests.java => ElasticSearchConfigTest.java} | 18 +-
...actTests.java => ElasticSearchExtractTest.java} | 47 +-
...dTests.java => ElasticSearchRawRecordTest.java} | 12 +-
...ests.java => ElasticSearchSinkRawDataTest.java} | 11 +-
...chSinkTests.java => ElasticSearchSinkTest.java} | 20 +-
.../io/elasticsearch/ElasticSearchTestBase.java | 6 +-
.../io/elasticsearch/IndexNameFormatterTest.java | 1 -
...nConverterTests.java => JsonConverterTest.java} | 55 +-
...yTests.java => RandomExponentialRetryTest.java} | 26 +-
.../client/RestClientFactoryTest.java | 4 +-
.../pulsar/io/elasticsearch/data/Profile.java | 1 -
.../pulsar/io/elasticsearch/data/UserProfile.java | 1 -
...tSslTests.java => OpenSearchClientSslTest.java} | 54 +-
...hClientTests.java => OpenSearchClientTest.java} | 6 +-
...taTests.java => OpenSearchSinkRawDataTest.java} | 6 +-
...earchSinkTests.java => OpenSearchSinkTest.java} | 6 +-
.../testcontainers/ElasticToxiproxiContainer.java | 9 +-
...7AuthTests.java => ElasticSearch7AuthTest.java} | 6 +-
...Tests.java => ElasticSearch7ClientSslTest.java} | 6 +-
...entTests.java => ElasticSearch7ClientTest.java} | 6 +-
...sts.java => ElasticSearch7SinkRawDataTest.java} | 6 +-
...7SinkTests.java => ElasticSearch7SinkTest.java} | 6 +-
...8AuthTests.java => ElasticSearch8AuthTest.java} | 6 +-
...Tests.java => ElasticSearch8ClientSslTest.java} | 6 +-
...entTests.java => ElasticSearch8ClientTest.java} | 6 +-
...sts.java => ElasticSearch8SinkRawDataTest.java} | 6 +-
...8SinkTests.java => ElasticSearch8SinkTest.java} | 6 +-
...bstractFileTests.java => AbstractFileTest.java} | 18 +-
...hreadTests.java => FileConsumerThreadTest.java} | 4 +-
...ThreadTests.java => FileListingThreadTest.java} | 6 +-
...eConfigTests.java => FileSourceConfigTest.java} | 50 +-
...readTests.java => ProcessedFileThreadTest.java} | 20 +-
.../apache/pulsar/io/file/TestFileGenerator.java | 22 +-
.../{GZipFilesTests.java => GZipFilesTest.java} | 16 +-
.../{ZipFilesTests.java => ZipFilesTest.java} | 16 +-
...tractFlumeTests.java => AbstractFlumeTest.java} | 2 +-
...TestAbstractZooKeeperConfigurationProvider.java | 3 +-
...PollingPropertiesFileConfigurationProvider.java | 2 +-
.../{StringSinkTests.java => StringSinkTest.java} | 9 +-
...tringSourceTests.java => StringSourceTest.java} | 6 +-
.../pulsar/io/hbase/sink/HbaseAbstractSink.java | 2 +-
.../org/apache/pulsar/io/hbase/TableUtils.java | 7 +-
.../io/hbase/sink/HbaseGenericRecordSinkTest.java | 27 +-
.../pulsar/io/hbase/sink/HbaseSinkConfigTest.java | 12 +-
.../pulsar/io/hdfs3/sink/AbstractHdfsSinkTest.java | 3 +-
.../pulsar/io/hdfs3/sink/HdfsSinkConfigTest.java | 150 +++++
.../pulsar/io/hdfs3/sink/HdfsSinkConfigTests.java | 155 -----
...lSinkTests.java => HdfsSequentialSinkTest.java} | 2 +-
...dfsTextSinkTests.java => HdfsTextSinkTest.java} | 2 +-
...tringSinkTests.java => HdfsStringSinkTest.java} | 2 +-
.../org/apache/pulsar/io/http/HttpSinkTest.java | 3 +-
.../influxdb/v1/InfluxDBGenericRecordSinkTest.java | 23 +-
.../io/influxdb/v1/InfluxDBSinkConfigTest.java | 16 +-
.../pulsar/io/influxdb/v2/InfluxDBSinkTest.java | 15 +-
.../pulsar/io/jdbc/BaseJdbcAutoSchemaSinkTest.java | 15 +-
.../org/apache/pulsar/io/jdbc/JdbcUtilsTest.java | 63 +-
.../pulsar/io/jdbc/SqliteJdbcSinkBatchTest.java | 4 +-
.../apache/pulsar/io/jdbc/SqliteJdbcSinkTest.java | 92 +--
.../org/apache/pulsar/io/jdbc/SqliteUtils.java | 6 +-
.../io/kafka/connect/KafkaConnectSinkTest.java | 124 ++--
.../connect/KafkaConnectSourceErrRecTest.java | 27 +-
.../kafka/connect/KafkaConnectSourceErrTest.java | 33 +-
.../io/kafka/connect/KafkaConnectSourceTest.java | 7 +-
.../io/kafka/connect/MockGenericObjectWrapper.java | 3 +-
.../connect/PulsarSchemaToKafkaSchemaTest.java | 18 +-
.../connect/SchemaedFileStreamSinkConnector.java | 5 +-
.../kafka/connect/SchemaedFileStreamSinkTask.java | 9 +-
.../io/kafka/ByteBufferSchemaWrapperTest.java | 14 +-
.../pulsar/io/kafka/KafkaBytesSourceTest.java | 12 +-
.../io/kafka/sink/KafkaAbstractSinkTest.java | 41 +-
.../io/kafka/source/KafkaAbstractSourceTest.java | 38 +-
.../pulsar/io/kinesis/KinesisSinkAuthTest.java | 36 +-
...ConfigTests.java => KinesisSinkConfigTest.java} | 6 +-
.../apache/pulsar/io/kinesis/KinesisSinkTest.java | 15 +-
...nfigTests.java => KinesisSourceConfigTest.java} | 7 +-
.../org/apache/pulsar/io/kinesis/UtilsTest.java | 4 -
...nConverterTests.java => JsonConverterTest.java} | 55 +-
.../pulsar/io/mongodb/MongoSinkConfigTest.java | 8 +-
.../apache/pulsar/io/mongodb/MongoSinkTest.java | 25 +-
.../apache/pulsar/io/mongodb/MongoSourceTest.java | 24 +-
.../pulsar/io/netty/NettySourceConfigTest.java | 10 +-
.../http/NettyHttpChannelInitializerTest.java | 7 +-
.../pulsar/io/netty/server/NettyServerTest.java | 12 +-
.../netty/tcp/NettyTCPChannelInitializerTest.java | 10 +-
.../netty/udp/NettyUDPChannelInitializerTest.java | 8 +-
.../{NSQConfigTests.java => NSQConfigTest.java} | 28 +-
.../io/rabbitmq/sink/RabbitMQSinkConfigTest.java | 16 +-
.../rabbitmq/source/RabbitMQSourceConfigTest.java | 18 +-
.../io/rabbitmq/source/RabbitMQSourceTest.java | 5 +-
.../apache/pulsar/io/redis/EmbeddedRedisUtils.java | 9 +-
.../pulsar/io/redis/sink/RedisSinkConfigTest.java | 20 +-
.../apache/pulsar/io/redis/sink/RedisSinkTest.java | 13 +-
.../pulsar/io/solr/SolrGenericRecordSinkTest.java | 16 +-
.../org/apache/pulsar/io/solr/SolrServerUtil.java | 9 +-
.../apache/pulsar/io/solr/SolrSinkConfigTest.java | 18 +-
...igTests.java => TwitterFireHoseConfigTest.java} | 30 +-
.../bookkeeper/PulsarLedgerIdGenerator.java | 2 +-
.../metadata/impl/PulsarZooKeeperClient.java | 5 +-
.../tableview/impl/MetadataStoreTableViewImpl.java | 2 +-
.../replication/AuditorLedgerCheckerTest.java | 2 +-
.../replication/TestReplicationWorker.java | 20 +-
.../metadata/BacklogQuotaCompatibilityTest.java | 8 +-
.../pulsar/metadata/BaseMetadataStoreTest.java | 2 +-
.../apache/pulsar/metadata/MetadataBenchmark.java | 40 +-
.../apache/pulsar/metadata/MetadataCacheTest.java | 10 +-
.../pulsar/metadata/MetadataStoreBatchingTest.java | 7 +-
.../pulsar/metadata/MetadataStoreExtendedTest.java | 3 +-
.../metadata/MetadataStoreTableViewTest.java | 17 +-
.../apache/pulsar/metadata/MetadataStoreTest.java | 17 +-
.../org/apache/pulsar/metadata/TestZKServer.java | 3 +-
.../org/apache/pulsar/metadata/ZKSessionTest.java | 6 +-
.../pulsar/metadata/bookkeeper/EndToEndTest.java | 2 +-
.../bookkeeper/PulsarLedgerIdGeneratorTest.java | 6 +-
.../bookkeeper/PulsarRegistrationClientTest.java | 13 +-
.../metadata/impl/EtcdMetadataStoreTest.java | 1 -
.../impl/LocalMemoryMetadataStoreTest.java | 39 +-
.../impl/MetadataStoreFactoryImplTest.java | 3 +-
.../bookkeeper/BookKeeperPackagesStorageTest.java | 2 +-
.../storage/bookkeeper/DLInputStreamTest.java | 12 +-
.../storage/bookkeeper/DLOutputStreamTest.java | 16 +-
.../bookkeeper/test/MockedBookKeeperTestCase.java | 2 +-
.../bookkeeper/bookkeeper/test/PortManager.java | 17 +-
.../bookkeeper/bookkeeper/test/ZooKeeperUtil.java | 16 +-
.../core/impl/PackagesManagementImplTest.java | 8 +-
.../filesystem/FileSystemPackagesStorageTest.java | 2 +-
.../pulsar/proxy/server/ProxyConnection.java | 4 +-
.../impl/AutoCloseUselessClientConProxyTest.java | 151 +++++
.../proxy/extensions/MockProxyExtension.java | 5 +-
.../proxy/extensions/ProxyExtensionUtilsTest.java | 17 +-
.../ProxyExtensionWithClassLoaderTest.java | 18 +-
.../proxy/extensions/ProxyExtensionsTest.java | 24 +-
.../extensions/SimpleProxyExtensionTestBase.java | 48 +-
.../server/AdminProxyHandlerKeystoreTLSTest.java | 21 +-
.../proxy/server/AuthedAdminProxyHandlerTest.java | 9 +-
.../proxy/server/BrokerProxyValidatorTest.java | 4 +-
.../proxy/server/FunctionWorkerRoutingTest.java | 11 +-
.../InvalidProxyConfigForAuthorizationTest.java | 1 -
.../proxy/server/ProxyAdditionalServletTest.java | 53 +-
.../ProxyAuthenticatedProducerConsumerTest.java | 36 +-
.../proxy/server/ProxyAuthenticationTest.java | 428 ++++++-------
.../proxy/server/ProxyConfigurationTest.java | 24 +-
.../server/ProxyConnectionThrottlingTest.java | 12 +-
.../server/ProxyEnableHAProxyProtocolTest.java | 16 +-
.../proxy/server/ProxyForwardAuthDataTest.java | 10 +-
.../pulsar/proxy/server/ProxyIsAHttpProxyTest.java | 29 +-
.../server/ProxyKeyStoreTlsTransportTest.java | 8 +-
.../proxy/server/ProxyKeyStoreTlsWithAuthTest.java | 9 +-
.../server/ProxyKeyStoreTlsWithoutAuthTest.java | 6 +-
.../proxy/server/ProxyLookupThrottlingTest.java | 19 +-
.../pulsar/proxy/server/ProxyMutualTlsTest.java | 22 +-
.../proxy/server/ProxyPrometheusMetricsTest.java | 3 +-
.../pulsar/proxy/server/ProxyRefreshAuthTest.java | 2 +-
.../proxy/server/ProxyRolesEnforcementTest.java | 3 +-
.../proxy/server/ProxyServiceStarterTest.java | 9 +-
.../proxy/server/ProxyServiceTlsStarterTest.java | 9 +-
.../apache/pulsar/proxy/server/ProxyStatsTest.java | 14 +-
.../org/apache/pulsar/proxy/server/ProxyTest.java | 38 +-
.../apache/pulsar/proxy/server/ProxyTlsTest.java | 16 +-
.../pulsar/proxy/server/ProxyTlsWithAuthTest.java | 21 +-
.../server/ProxyWithAuthorizationNegTest.java | 51 +-
.../proxy/server/ProxyWithAuthorizationTest.java | 123 ++--
.../server/ProxyWithJwtAuthorizationTest.java | 42 +-
.../server/ProxyWithoutServiceDiscoveryTest.java | 15 +-
.../SuperUserAuthedAdminProxyHandlerTest.java | 12 +-
.../server/UnauthedAdminProxyHandlerTest.java | 8 +-
.../proxy/util/CmdGenerateDocumentationTest.java | 2 +-
.../proxy/socket/client/PerformanceClientTest.java | 4 +-
.../Oauth2PerformanceTransactionTest.java | 2 +-
.../pulsar/testclient/PerfClientUtilsTest.java | 6 +-
.../testclient/PerformanceBaseArgumentsTest.java | 6 +-
.../pulsar/testclient/PerformanceProducerTest.java | 8 +-
.../testclient/PerformanceTransactionTest.java | 11 +-
.../testclient/TestDefaultMessageFormatter.java | 10 +-
.../MLTransactionMetadataStoreTest.java | 24 +-
.../TransactionMetadataStoreProviderTest.java | 2 -
.../transaction/coordinator/TxnStatusTest.java | 8 +-
.../coordinator/impl/MLTransactionLogImplTest.java | 37 +-
.../impl/TxnBatchedPositionImplTest.java | 10 +-
.../coordinator/impl/TxnLogBufferedWriterTest.java | 48 +-
.../coordinator/test/MockedBookKeeperTestCase.java | 2 +-
.../websocket/AbstractWebSocketHandlerTest.java | 17 +-
.../pulsar/websocket/LookupProtocolTest.java | 16 +-
.../pulsar/websocket/PingPongSupportTest.java | 11 +-
.../pulsar/websocket/ProducerHandlerTest.java | 32 +-
.../apache/pulsar/websocket/ReaderHandlerTest.java | 28 +-
.../WebSocketHttpServletRequestWrapperTest.java | 6 +-
.../websocket/WebSocketProxyConfigurationTest.java | 17 +-
.../websocket/admin/WebSocketWebResourceTest.java | 23 +-
.../service/WebSocketProxyConfigurationTest.java | 20 +-
.../slf4j/StructuredEventLogTest.java | 23 +-
.../bookkeeper/client/TestStatsProvider.java | 4 +-
.../pulsar/tests/integration/PulsarContainer.java | 6 +-
.../apache/pulsar/tests/integration/SmokeTest.java | 3 +-
.../pulsar/tests/integration/PulsarContainer.java | 6 +-
.../apache/pulsar/tests/integration/SmokeTest.java | 3 +-
.../pulsar/tests/integration/PulsarContainer.java | 6 +-
.../apache/pulsar/tests/integration/SmokeTest.java | 3 +-
.../pulsar/tests/integration/admin/AdminTest.java | 1 -
.../token/PulsarTokenAuthenticationBaseSuite.java | 8 +-
.../auth/token/TokenAuthWithPublicPrivateKeys.java | 3 -
.../auth/token/TokenAuthWithSymmetricKeys.java | 4 +-
.../{ClientTest2_2.java => ClientTest22.java} | 5 +-
.../{ClientTest2_3.java => ClientTest23.java} | 5 +-
.../{ClientTest2_4.java => ClientTest24.java} | 5 +-
.../{ClientTest2_5.java => ClientTest25.java} | 5 +-
...te2_2.java => PulsarStandaloneTestSuite22.java} | 4 +-
...te2_3.java => PulsarStandaloneTestSuite23.java} | 4 +-
...te2_4.java => PulsarStandaloneTestSuite24.java} | 4 +-
...te2_5.java => PulsarStandaloneTestSuite25.java} | 4 +-
.../{SmokeTest2_2.java => SmokeTest22.java} | 2 +-
.../{SmokeTest2_3.java => SmokeTest23.java} | 2 +-
.../{SmokeTest2_4.java => SmokeTest24.java} | 2 +-
.../{SmokeTest2_5.java => SmokeTest25.java} | 2 +-
...BookkeeperInstallWithHttpServerEnabledTest.java | 8 +-
...erInstallWithEntryMetadataInterceptorsTest.java | 11 +-
.../pulsar/tests/integration/cli/CLITest.java | 2 +-
.../tests/integration/cli/ClientToolTest.java | 15 +-
.../cli/ClusterMetadataTearDownTest.java | 5 +-
.../integration/cli/FileSystemPackagesCliTest.java | 12 +-
.../tests/integration/cli/FunctionsCLITest.java | 1 -
.../tests/integration/cli/HealthCheckTest.java | 5 -
.../tests/integration/cli/PackagesCliTest.java | 14 +-
.../pulsar/tests/integration/cli/PerfToolTest.java | 42 +-
.../tests/integration/cli/PulsarVersionTest.java | 4 +-
.../integration/cli/SchemaUpdateStrategyTest.java | 25 +-
.../SchemaCompatibilityStrategyTest.java | 5 +-
.../integration/compaction/TestCompaction.java | 25 +-
.../integration/containers/ChaosContainer.java | 3 +-
.../containers/DebeziumMsSqlContainer.java | 4 +-
.../containers/DebeziumOracleDbContainer.java | 4 +-
.../integration/containers/HdfsContainer.java | 30 +-
.../containers/PulsarInitMetadataContainer.java | 2 +-
.../tests/integration/containers/S3Container.java | 2 +-
.../containers/StandaloneContainer.java | 1 -
.../integration/functions/PulsarFunctionsTest.java | 25 +-
.../integration/functions/PulsarStateTest.java | 15 +-
.../functions/go/PulsarFunctionsGoTest.java | 6 +-
.../functions/java/PulsarFunctionsJavaTest.java | 8 +-
.../java/PulsarWorkerRebalanceDrainTest.java | 55 +-
.../python/PulsarFunctionsPythonTest.java | 6 +-
.../python/PulsarFunctionsPythonThreadTest.java | 2 +-
.../functions/utils/CommandGenerator.java | 4 +-
.../io/PulsarGenericObjectSinkTest.java | 41 +-
.../tests/integration/io/PulsarIOTestRunner.java | 18 +-
.../tests/integration/io/RabbitMQSinkTester.java | 19 +-
.../tests/integration/io/RabbitMQSourceTester.java | 8 +-
.../io/SinkWithTransformFunctionTest.java | 4 +-
.../integration/io/sinks/CassandraSinkTester.java | 15 +-
.../io/sinks/ElasticSearchSinkTester.java | 4 +-
.../tests/integration/io/sinks/HdfsSinkTester.java | 73 ++-
.../io/sinks/JdbcPostgresSinkTester.java | 21 +-
.../integration/io/sinks/KinesisSinkTester.java | 21 +-
.../integration/io/sinks/PulsarIOSinkRunner.java | 39 +-
.../tests/integration/io/sinks/SinkTester.java | 1 -
.../io/sources/AvroKafkaSourceTest.java | 30 +-
.../integration/io/sources/BatchSourceTest.java | 24 +-
.../io/sources/GenericRecordSourceTest.java | 11 +-
.../integration/io/sources/KafkaSourceTester.java | 1 -
.../integration/io/sources/MongoSourceTester.java | 30 +-
.../io/sources/PulsarIOSourceRunner.java | 26 +-
.../io/sources/PulsarSourcePropertyTest.java | 12 +-
.../tests/integration/io/sources/SourceTester.java | 24 +-
.../debezium/DebeziumMongoDbSourceTester.java | 42 +-
.../debezium/DebeziumMsSqlSourceTester.java | 12 +-
.../debezium/DebeziumMySqlSourceTester.java | 20 +-
.../debezium/DebeziumOracleDbSourceTester.java | 15 +-
.../debezium/DebeziumPostgreSqlSourceTester.java | 34 +-
.../debezium/PulsarDebeziumOracleSourceTest.java | 9 +-
.../debezium/PulsarDebeziumSourcesTest.java | 26 +-
.../debezium/PulsarIODebeziumSourceRunner.java | 5 +-
.../loadbalance/ExtensibleLoadManagerTest.java | 4 +-
.../integration/messaging/GeoReplicationTest.java | 12 +-
.../tests/integration/messaging/MessagingBase.java | 16 +-
.../integration/messaging/TopicMessagingBase.java | 31 +-
.../metrics/OpenTelemetrySanityTest.java | 3 +-
.../tests/integration/offload/TestBaseOffload.java | 17 +-
.../integration/offload/TestFileSystemOffload.java | 14 +-
.../integration/offload/TestOffloadDeletionFS.java | 14 +-
.../tests/integration/offload/TestS3Offload.java | 10 +-
.../offload/TestUniversalConfigurations.java | 14 +-
.../tests/integration/oxia/OxiaSmokeTest.java | 2 +-
.../plugins/TestAdditionalServlets.java | 13 +-
.../plugins/TestBrokerInterceptors.java | 7 +-
.../integration/plugins/TestEntryFilters.java | 6 +-
.../tests/integration/python/PythonSchemaTest.java | 8 +-
.../tests/integration/schema/JodaTimeTest.java | 24 +-
.../tests/integration/schema/SchemaTest.java | 25 +-
.../pulsar/tests/integration/schema/Schemas.java | 22 +-
.../tests/integration/semantics/SemanticsTest.java | 5 +-
.../tests/integration/suites/PulsarTestSuite.java | 7 +-
.../tests/integration/tls/ClientTlsTest.java | 6 +-
.../integration/topics/TestTopicDeletion.java | 26 +-
.../integration/topologies/ClientTestBase.java | 8 +-
.../integration/topologies/PulsarCluster.java | 2 +-
.../integration/topologies/PulsarClusterSpec.java | 10 +-
.../topologies/PulsarClusterTestBase.java | 6 +-
.../integration/topologies/PulsarGeoCluster.java | 2 +-
.../topologies/PulsarGeoClusterTestBase.java | 1 -
.../upgrade/PulsarUpgradeDowngradeTest.java | 11 +-
.../tests/integration/websocket/TestWebSocket.java | 4 +-
.../integration/websocket/WebSocketTestSuite.java | 24 +-
.../resources/pulsar-backwards-compatibility.xml | 16 +-
.../pulsar/tests/integration/PulsarContainer.java | 6 +-
.../integration/SimpleProducerConsumerTest.java | 101 +--
.../apache/pulsar/tests/integration/SmokeTest.java | 7 +-
.../pulsar/tests/integration/PulsarContainer.java | 6 +-
.../integration/SimpleProducerConsumerTest.java | 97 +--
.../apache/pulsar/tests/integration/SmokeTest.java | 7 +-
.../pulsar/tests/integration/PulsarContainer.java | 6 +-
.../integration/SimpleProducerConsumerTest.java | 97 +--
.../apache/pulsar/tests/integration/SmokeTest.java | 3 +-
.../offload/filesystem/FileStoreTestBase.java | 2 +-
.../impl/FileSystemManagedLedgerOffloaderTest.java | 12 +-
.../impl/FileSystemOffloaderLocalFileTest.java | 12 +-
.../jcloud/BlobStoreBackedInputStreamTest.java | 30 +-
.../mledger/offload/jcloud/BlobStoreTestBase.java | 6 +-
.../impl/BlobStoreManagedLedgerOffloaderBase.java | 10 +-
...obStoreManagedLedgerOffloaderStreamingTest.java | 6 +-
.../impl/BlobStoreManagedLedgerOffloaderTest.java | 63 +-
.../impl/BlockAwareSegmentInputStreamTest.java | 33 +-
.../jcloud/impl/BufferedOffloadStreamTest.java | 2 +-
.../offload/jcloud/impl/DataBlockHeaderTest.java | 6 +-
.../offload/jcloud/impl/DataBlockUtilsTest.java | 5 +-
.../offload/jcloud/impl/OffloadIndexTest.java | 11 +-
.../offload/jcloud/impl/OffsetsCacheTest.java | 4 +-
.../AbstractJCloudBlobStoreFactoryTest.java | 37 +-
...Tests.java => JCloudBlobStoreProviderTest.java} | 42 +-
...ts.java => TieredStorageConfigurationTest.java} | 58 +-
...sts.java => TransientBlobStoreFactoryTest.java} | 14 +-
1179 files changed, 13852 insertions(+), 11082 deletions(-)
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/{V1_AdminApi2Test.java
=> V1AdminApi2Test.java} (99%)
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/{V1_AdminApiTest.java
=> V1AdminApiTest.java} (98%)
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/namespace/{NamespaceOwnershipListenerTests.java
=> NamespaceOwnershipListenerTest.java} (98%)
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/{BrokerBkEnsemblesTests.java
=> BrokerBkEnsemblesTest.java} (97%)
rename
pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/{V1_ProducerConsumerBase.java
=> V1ProducerConsumerBase.java} (96%)
rename
pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/{V1_ProducerConsumerTest.java
=> V1ProducerConsumerTest.java} (96%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/AutoCloseUselessClientConTopicsPatternConsumerTest.java
rename
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/{DispatchAccordingPermitsTests.java
=> DispatchAccordingPermitsTest.java} (98%)
rename
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/v1/{V1_ProxyAuthenticationTest.java
=> V1ProxyAuthenticationTest.java} (91%)
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/ClientCnxIdleStateTest.java
rename
pulsar-common/src/test/java/org/apache/pulsar/common/naming/{MetadataTests.java
=> MetadataTest.java} (99%)
rename
pulsar-common/src/test/java/org/apache/pulsar/common/protocol/{CommandUtilsTests.java
=> CommandUtilsTest.java} (92%)
rename
pulsar-io/dynamodb/src/test/java/org/apache/pulsar/io/dynamodb/{DynamoDBSourceConfigTests.java
=> DynamoDBSourceConfigTest.java} (90%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{ElasticSearchAuthTests.java
=> ElasticSearchAuthTest.java} (97%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{ElasticSearchBWCTests.java
=> ElasticSearchBWCTest.java} (93%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{ElasticSearchClientSslTests.java
=> ElasticSearchClientSslTest.java} (77%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{ElasticSearchClientTests.java
=> ElasticSearchClientTest.java} (96%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{ElasticSearchConfigTests.java
=> ElasticSearchConfigTest.java} (99%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{ElasticSearchExtractTests.java
=> ElasticSearchExtractTest.java} (93%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{ElasticSearchRawRecordTests.java
=> ElasticSearchRawRecordTest.java} (99%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{ElasticSearchSinkRawDataTests.java
=> ElasticSearchSinkRawDataTest.java} (94%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{ElasticSearchSinkTests.java
=> ElasticSearchSinkTest.java} (97%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{JsonConverterTests.java
=> JsonConverterTest.java} (89%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/{RandomExponentialRetryTests.java
=> RandomExponentialRetryTest.java} (87%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/opensearch/{OpenSearchClientSslTests.java
=> OpenSearchClientSslTest.java} (81%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/opensearch/{OpenSearchClientTests.java
=> OpenSearchClientTest.java} (89%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/opensearch/{OpenSearchSinkRawDataTests.java
=> OpenSearchSinkRawDataTest.java} (88%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/opensearch/{OpenSearchSinkTests.java
=> OpenSearchSinkTest.java} (84%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v7/{ElasticSearch7AuthTests.java
=> ElasticSearch7AuthTest.java} (83%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v7/{ElasticSearch7ClientSslTests.java
=> ElasticSearch7ClientSslTest.java} (88%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v7/{ElasticSearch7ClientTests.java
=> ElasticSearch7ClientTest.java} (88%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v7/{ElasticSearch7SinkRawDataTests.java
=> ElasticSearch7SinkRawDataTest.java} (87%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v7/{ElasticSearch7SinkTests.java
=> ElasticSearch7SinkTest.java} (83%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v8/{ElasticSearch8AuthTests.java
=> ElasticSearch8AuthTest.java} (83%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v8/{ElasticSearch8ClientSslTests.java
=> ElasticSearch8ClientSslTest.java} (88%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v8/{ElasticSearch8ClientTests.java
=> ElasticSearch8ClientTest.java} (88%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v8/{ElasticSearch8SinkRawDataTests.java
=> ElasticSearch8SinkRawDataTest.java} (87%)
rename
pulsar-io/elastic-search/src/test/java/org/apache/pulsar/io/elasticsearch/v8/{ElasticSearch8SinkTests.java
=> ElasticSearch8SinkTest.java} (83%)
rename
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/{AbstractFileTests.java
=> AbstractFileTest.java} (90%)
rename
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/{FileConsumerThreadTests.java
=> FileConsumerThreadTest.java} (98%)
rename
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/{FileListingThreadTests.java
=> FileListingThreadTest.java} (99%)
rename
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/{FileSourceConfigTests.java
=> FileSourceConfigTest.java} (87%)
rename
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/{ProcessedFileThreadTests.java
=> ProcessedFileThreadTest.java} (96%)
rename
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/utils/{GZipFilesTests.java
=> GZipFilesTest.java} (97%)
rename
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/utils/{ZipFilesTests.java
=> ZipFilesTest.java} (97%)
rename
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/{AbstractFlumeTests.java
=> AbstractFlumeTest.java} (95%)
rename
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/sink/{StringSinkTests.java
=> StringSinkTest.java} (96%)
rename
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/source/{StringSourceTests.java
=> StringSourceTest.java} (95%)
create mode 100644
pulsar-io/hdfs3/src/test/java/org/apache/pulsar/io/hdfs3/sink/HdfsSinkConfigTest.java
delete mode 100644
pulsar-io/hdfs3/src/test/java/org/apache/pulsar/io/hdfs3/sink/HdfsSinkConfigTests.java
rename
pulsar-io/hdfs3/src/test/java/org/apache/pulsar/io/hdfs3/sink/seq/{HdfsSequentialSinkTests.java
=> HdfsSequentialSinkTest.java} (97%)
rename
pulsar-io/hdfs3/src/test/java/org/apache/pulsar/io/hdfs3/sink/seq/{HdfsTextSinkTests.java
=> HdfsTextSinkTest.java} (97%)
rename
pulsar-io/hdfs3/src/test/java/org/apache/pulsar/io/hdfs3/sink/text/{HdfsStringSinkTests.java
=> HdfsStringSinkTest.java} (97%)
rename
pulsar-io/kinesis/src/test/java/org/apache/pulsar/io/kinesis/{KinesisSinkConfigTests.java
=> KinesisSinkConfigTest.java} (97%)
rename
pulsar-io/kinesis/src/test/java/org/apache/pulsar/io/kinesis/{KinesisSourceConfigTests.java
=> KinesisSourceConfigTest.java} (97%)
rename
pulsar-io/kinesis/src/test/java/org/apache/pulsar/io/kinesis/json/{JsonConverterTests.java
=> JsonConverterTest.java} (89%)
rename
pulsar-io/nsq/src/test/java/org/apache/pulsar/io/nsq/{NSQConfigTests.java =>
NSQConfigTest.java} (95%)
rename
pulsar-io/twitter/src/test/java/org/apache/pulsar/io/twitter/{TwitterFireHoseConfigTests.java
=> TwitterFireHoseConfigTest.java} (94%)
create mode 100644
pulsar-proxy/src/test/java/org/apache/pulsar/client/impl/AutoCloseUselessClientConProxyTest.java
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{ClientTest2_2.java
=> ClientTest22.java} (91%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{ClientTest2_3.java
=> ClientTest23.java} (91%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{ClientTest2_4.java
=> ClientTest24.java} (91%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{ClientTest2_5.java
=> ClientTest25.java} (91%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{PulsarStandaloneTestSuite2_2.java
=> PulsarStandaloneTestSuite22.java} (89%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{PulsarStandaloneTestSuite2_3.java
=> PulsarStandaloneTestSuite23.java} (89%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{PulsarStandaloneTestSuite2_4.java
=> PulsarStandaloneTestSuite24.java} (89%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{PulsarStandaloneTestSuite2_5.java
=> PulsarStandaloneTestSuite25.java} (89%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{SmokeTest2_2.java
=> SmokeTest22.java} (95%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{SmokeTest2_3.java
=> SmokeTest23.java} (95%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{SmokeTest2_4.java
=> SmokeTest24.java} (96%)
rename
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{SmokeTest2_5.java
=> SmokeTest25.java} (96%)
rename
tiered-storage/jcloud/src/test/java/org/apache/bookkeeper/mledger/offload/jcloud/provider/{JCloudBlobStoreProviderTests.java
=> JCloudBlobStoreProviderTest.java} (87%)
rename
tiered-storage/jcloud/src/test/java/org/apache/bookkeeper/mledger/offload/jcloud/provider/{TieredStorageConfigurationTests.java
=> TieredStorageConfigurationTest.java} (95%)
rename
tiered-storage/jcloud/src/test/java/org/apache/bookkeeper/mledger/offload/jcloud/provider/{TransientBlobStoreFactoryTests.java
=> TransientBlobStoreFactoryTest.java} (89%)
