## ๐ดย fixtures/external/java/pulsar-test-report.xml
**808** tests were completed in **2127s** with **793** passed, **1** failed and **14** skipped.
|Test suite|Passed|Failed|Skipped|Time|
|:---|---:|---:|---:|---:|
|๐ด [org.apache.pulsar.AddMissingPatchVersionTest](#r0s0)||1|1|116ms|
|๐ข [org.apache.pulsar.broker.admin.AdminApiOffloadTest](#r0s1)|7|||19s|
|๐ข [org.apache.pulsar.broker.auth.AuthenticationServiceTest](#r0s2)|2|||185ms|
|๐ข [org.apache.pulsar.broker.auth.AuthLogsTest](#r0s3)|2|||1s|
|๐ข [org.apache.pulsar.broker.auth.AuthorizationTest](#r0s4)|1|||2s|
|๐ข [org.apache.pulsar.broker.lookup.http.HttpTopicLookupv2Test](#r0s5)|4|||2s|
|๐ข [org.apache.pulsar.broker.namespace.NamespaceCreateBundlesTest](#r0s6)|2|||33s|
|๐ข [org.apache.pulsar.broker.namespace.NamespaceOwnershipListenerTests](#r0s7)|2|||32s|
|๐ข [org.apache.pulsar.broker.namespace.NamespaceServiceTest](#r0s8)|10|||75s|
|๐ข [org.apache.pulsar.broker.namespace.NamespaceUnloadingTest](#r0s9)|2|||14s|
|๐ข [org.apache.pulsar.broker.namespace.OwnerShipCacheForCurrentServerTest](#r0s10)|1|||16s|
|๐ข [org.apache.pulsar.broker.namespace.OwnershipCacheTest](#r0s11)|8|||16s|
|๐ข [org.apache.pulsar.broker.protocol.ProtocolHandlersTest](#r0s12)|6|||946ms|
|๐ข [org.apache.pulsar.broker.protocol.ProtocolHandlerUtilsTest](#r0s13)|3|||7s|
|๐ข [org.apache.pulsar.broker.protocol.ProtocolHandlerWithClassLoaderTest](#r0s14)|1|||15ms|
|๐ข [org.apache.pulsar.broker.PulsarServiceTest](#r0s15)|2|||96ms|
|๐ข [org.apache.pulsar.broker.service.MessagePublishBufferThrottleTest](#r0s16)|3|||14s|
|๐ข [org.apache.pulsar.broker.service.ReplicatorTest](#r0s17)|22|||40s|
|๐ข [org.apache.pulsar.broker.service.TopicOwnerTest](#r0s18)|8|||114s|
|๐ข [org.apache.pulsar.broker.SLAMonitoringTest](#r0s19)|4|||9s|
|๐ข [org.apache.pulsar.broker.stats.BookieClientsStatsGeneratorTest](#r0s20)|2|||49ms|
|๐ข [org.apache.pulsar.broker.stats.ConsumerStatsTest](#r0s21)|3|||21s|
|๐ข [org.apache.pulsar.broker.stats.ManagedCursorMetricsTest](#r0s22)|1|||281ms|
|๐ข [org.apache.pulsar.broker.stats.ManagedLedgerMetricsTest](#r0s23)|1|||285ms|
|๐ข [org.apache.pulsar.broker.stats.prometheus.AggregatedNamespaceStatsTest](#r0s24)|1|||40ms|
|๐ข [org.apache.pulsar.broker.stats.PrometheusMetricsTest](#r0s25)|15|||83s|
|๐ข [org.apache.pulsar.broker.stats.SubscriptionStatsTest](#r0s26)|2|||2s|
|๐ข [org.apache.pulsar.broker.systopic.NamespaceEventsSystemTopicServiceTest](#r0s27)|1|||1s|
|๐ข [org.apache.pulsar.broker.transaction.buffer.InMemTransactionBufferReaderTest](#r0s28)|3|||28ms|
|๐ข [org.apache.pulsar.broker.transaction.buffer.TransactionBufferClientTest](#r0s29)|4|||93ms|
|๐ข [org.apache.pulsar.broker.transaction.buffer.TransactionBufferTest](#r0s30)|7|||81ms|
|๐ข [org.apache.pulsar.broker.transaction.buffer.TransactionEntryImplTest](#r0s31)|1|||14ms|
|๐ข [org.apache.pulsar.broker.transaction.buffer.TransactionLowWaterMarkTest](#r0s32)|2|||38s|
|๐ข [org.apache.pulsar.broker.transaction.buffer.TransactionStablePositionTest](#r0s33)|2||1|49s|
|๐ข [org.apache.pulsar.broker.transaction.coordinator.TransactionCoordinatorClientTest](#r0s34)|3|||95ms|
|๐ข [org.apache.pulsar.broker.transaction.coordinator.TransactionMetaStoreAssignmentTest](#r0s35)|1|||1s|
|๐ข [org.apache.pulsar.broker.transaction.pendingack.PendingAckInMemoryDeleteTest](#r0s36)|2||1|57s|
|๐ข [org.apache.pulsar.broker.transaction.TransactionConsumeTest](#r0s37)|2|||30s|
|๐ข [org.apache.pulsar.broker.web.RestExceptionTest](#r0s38)|3|||37ms|
|๐ข [org.apache.pulsar.broker.web.WebServiceTest](#r0s39)|9|||27s|
|๐ข [org.apache.pulsar.client.impl.AdminApiKeyStoreTlsAuthTest](#r0s40)|4|||8s|
|๐ข [org.apache.pulsar.client.impl.BatchMessageIdImplSerializationTest](#r0s41)|4|||30ms|
|๐ข [org.apache.pulsar.client.impl.BatchMessageIndexAckDisableTest](#r0s42)|4|||14s|
|๐ข [org.apache.pulsar.client.impl.BatchMessageIndexAckTest](#r0s43)|5|||44s|
|๐ข [org.apache.pulsar.client.impl.BrokerClientIntegrationTest](#r0s44)|15|||148s|
|๐ข [org.apache.pulsar.client.impl.CompactedOutBatchMessageTest](#r0s45)|1|||1s|
|๐ข [org.apache.pulsar.client.impl.ConsumerAckResponseTest](#r0s46)|1|||549ms|
|๐ข [org.apache.pulsar.client.impl.ConsumerConfigurationTest](#r0s47)|4|||12s|
|๐ข [org.apache.pulsar.client.impl.ConsumerDedupPermitsUpdate](#r0s48)|7|||4s|
|๐ข [org.apache.pulsar.client.impl.ConsumerUnsubscribeTest](#r0s49)|1|||129ms|
|๐ข [org.apache.pulsar.client.impl.KeyStoreTlsProducerConsumerTestWithAuth](#r0s50)|3|||23s|
|๐ข [org.apache.pulsar.client.impl.KeyStoreTlsProducerConsumerTestWithoutAuth](#r0s51)|3|||8s|
|๐ข [org.apache.pulsar.client.impl.KeyStoreTlsTest](#r0s52)|1|||183ms|
|๐ข [org.apache.pulsar.client.impl.MessageChecksumTest](#r0s53)|3|||47s|
|๐ข [org.apache.pulsar.client.impl.MessageChunkingTest](#r0s54)|8||1|73s|
|๐ข [org.apache.pulsar.client.impl.MessageParserTest](#r0s55)|2|||5s|
|๐ข [org.apache.pulsar.client.impl.MultiTopicsReaderTest](#r0s56)|8|||35s|
|๐ข [org.apache.pulsar.client.impl.NegativeAcksTest](#r0s57)|32|||11s|
|๐ข [org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest](#r0s58)|11|||63s|
|๐ข [org.apache.pulsar.client.impl.PerMessageUnAcknowledgedRedeliveryTest](#r0s59)|5|||34s|
|๐ข [org.apache.pulsar.client.impl.PulsarMultiHostClientTest](#r0s60)|3|||15s|
|๐ข [org.apache.pulsar.client.impl.RawMessageSerDeserTest](#r0s61)|1|||10ms|
|๐ข [org.apache.pulsar.client.impl.SchemaDeleteTest](#r0s62)|1|||2s|
|๐ข [org.apache.pulsar.client.impl.SequenceIdWithErrorTest](#r0s63)|3||2|18s|
|๐ข [org.apache.pulsar.client.impl.TopicDoesNotExistsTest](#r0s64)|2|||4s|
|๐ข [org.apache.pulsar.client.impl.TopicFromMessageTest](#r0s65)|5|||14s|
|๐ข [org.apache.pulsar.client.impl.TopicsConsumerImplTest](#r0s66)|17|||133s|
|๐ข [org.apache.pulsar.client.impl.UnAcknowledgedMessagesTimeoutTest](#r0s67)|7|||44s|
|๐ข [org.apache.pulsar.client.impl.ZeroQueueSizeTest](#r0s68)|14|||16s|
|๐ข [org.apache.pulsar.common.api.raw.RawMessageImplTest](#r0s69)|1|||316ms|
|๐ข [org.apache.pulsar.common.compression.CommandsTest](#r0s70)|1|||30ms|
|๐ข [org.apache.pulsar.common.compression.CompressorCodecBackwardCompatTest](#r0s71)|6|||223ms|
|๐ข [org.apache.pulsar.common.compression.CompressorCodecTest](#r0s72)|45|||737ms|
|๐ข [org.apache.pulsar.common.compression.Crc32cChecksumTest](#r0s73)|6|||5s|
|๐ข [org.apache.pulsar.common.lookup.data.LookupDataTest](#r0s74)|4|||2s|
|๐ข [org.apache.pulsar.common.naming.MetadataTests](#r0s75)|2|||161ms|
|๐ข [org.apache.pulsar.common.naming.NamespaceBundlesTest](#r0s76)|5|||99ms|
|๐ข [org.apache.pulsar.common.naming.NamespaceBundleTest](#r0s77)|6|||64ms|
|๐ข [org.apache.pulsar.common.naming.NamespaceNameTest](#r0s78)|2|||207ms|
|๐ข [org.apache.pulsar.common.naming.ServiceConfigurationTest](#r0s79)|4|||48ms|
|๐ข [org.apache.pulsar.common.naming.TopicNameTest](#r0s80)|4|||529ms|
|๐ข [org.apache.pulsar.common.net.ServiceURITest](#r0s81)|21|||237ms|
|๐ข [org.apache.pulsar.common.policies.data.AutoFailoverPolicyDataTest](#r0s82)|1|||15ms|
|๐ข [org.apache.pulsar.common.policies.data.AutoFailoverPolicyTypeTest](#r0s83)|1|||19ms|
|๐ข [org.apache.pulsar.common.policies.data.AutoTopicCreationOverrideTest](#r0s84)|6|||64ms|
|๐ข [org.apache.pulsar.common.policies.data.BacklogQuotaTest](#r0s85)|1|||12ms|
|๐ข [org.apache.pulsar.common.policies.data.ClusterDataTest](#r0s86)|1|||9ms|
|๐ข [org.apache.pulsar.common.policies.data.ConsumerStatsTest](#r0s87)|1|||8ms|
|๐ข [org.apache.pulsar.common.policies.data.EnsemblePlacementPolicyConfigTest](#r0s88)|2|||948ms|
|๐ข [org.apache.pulsar.common.policies.data.LocalPolicesTest](#r0s89)|1|||48ms|
|๐ข [org.apache.pulsar.common.policies.data.NamespaceIsolationDataTest](#r0s90)|1|||76ms|
|๐ข [org.apache.pulsar.common.policies.data.NamespaceOwnershipStatusTest](#r0s91)|1|||45ms|
|๐ข [org.apache.pulsar.common.policies.data.OffloadPoliciesTest](#r0s92)|6|||216ms|
|๐ข [org.apache.pulsar.common.policies.data.PartitionedTopicStatsTest](#r0s93)|1|||12ms|
|๐ข [org.apache.pulsar.common.policies.data.PersistencePoliciesTest](#r0s94)|1|||19ms|
|๐ข [org.apache.pulsar.common.policies.data.PersistentOfflineTopicStatsTest](#r0s95)|1|||29ms|
|๐ข [org.apache.pulsar.common.policies.data.PersistentTopicStatsTest](#r0s96)|2|||51ms|
|๐ข [org.apache.pulsar.common.policies.data.PoliciesDataTest](#r0s97)|4|||1s|
|๐ข [org.apache.pulsar.common.policies.data.PublisherStatsTest](#r0s98)|2|||37ms|
|๐ข [org.apache.pulsar.common.policies.data.ReplicatorStatsTest](#r0s99)|2|||30ms|
|๐ข [org.apache.pulsar.common.policies.data.ResourceQuotaTest](#r0s100)|2|||45ms|
|๐ข [org.apache.pulsar.common.policies.data.RetentionPolicesTest](#r0s101)|1|||8ms|
|๐ข [org.apache.pulsar.common.policies.impl.AutoFailoverPolicyFactoryTest](#r0s102)|1|||22ms|
|๐ข [org.apache.pulsar.common.policies.impl.MinAvailablePolicyTest](#r0s103)|1|||1ms|
|๐ข [org.apache.pulsar.common.policies.impl.NamespaceIsolationPoliciesTest](#r0s104)|7|||265ms|
|๐ข [org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImplTest](#r0s105)|7|||309ms|
|๐ข [org.apache.pulsar.common.protocol.ByteBufPairTest](#r0s106)|2|||5s|
|๐ข [org.apache.pulsar.common.protocol.CommandUtilsTests](#r0s107)|7|||3s|
|๐ข [org.apache.pulsar.common.protocol.MarkersTest](#r0s108)|6|||3s|
|๐ข [org.apache.pulsar.common.protocol.PulsarDecoderTest](#r0s109)|1|||4s|
|๐ข [org.apache.pulsar.common.stats.JvmDefaultGCMetricsLoggerTest](#r0s110)|1|||82ms|
|๐ข [org.apache.pulsar.common.util.collections.BitSetRecyclableRecyclableTest](#r0s111)|2|||13ms|
|๐ข [org.apache.pulsar.common.util.collections.ConcurrentBitSetRecyclableTest](#r0s112)|2|||63ms|
|๐ข [org.apache.pulsar.common.util.collections.ConcurrentLongHashMapTest](#r0s113)|13|||28s|
|๐ข [org.apache.pulsar.common.util.collections.ConcurrentLongPairSetTest](#r0s114)|15|||2s|
|๐ข [org.apache.pulsar.common.util.collections.ConcurrentOpenHashMapTest](#r0s115)|12|||9s|
|๐ข [org.apache.pulsar.common.util.collections.ConcurrentOpenHashSetTest](#r0s116)|11|||7s|
|๐ข [org.apache.pulsar.common.util.collections.ConcurrentOpenLongPairRangeSetTest](#r0s117)|13|||1s|
|๐ข [org.apache.pulsar.common.util.collections.ConcurrentSortedLongPairSetTest](#r0s118)|9|||342ms|
|๐ข [org.apache.pulsar.common.util.collections.FieldParserTest](#r0s119)|2|||64ms|
|๐ข [org.apache.pulsar.common.util.collections.GrowableArrayBlockingQueueTest](#r0s120)|6|||350ms|
|๐ข [org.apache.pulsar.common.util.collections.GrowablePriorityLongPairQueueTest](#r0s121)|15|||3s|
|๐ข [org.apache.pulsar.common.util.collections.TripleLongPriorityQueueTest](#r0s122)|3|||238ms|
|๐ข [org.apache.pulsar.common.util.FieldParserTest](#r0s123)|1|||242ms|
|๐ข [org.apache.pulsar.common.util.FileModifiedTimeUpdaterTest](#r0s124)|6|||6s|
|๐ข [org.apache.pulsar.common.util.netty.ChannelFuturesTest](#r0s125)|5|||2s|
|๐ข [org.apache.pulsar.common.util.RateLimiterTest](#r0s126)|11|||7s|
|๐ข [org.apache.pulsar.common.util.ReflectionsTest](#r0s127)|12|||172ms|
|๐ข [org.apache.pulsar.common.util.RelativeTimeUtilTest](#r0s128)|1|||39ms|
|๐ข [org.apache.pulsar.discovery.service.web.DiscoveryServiceWebTest](#r0s129)|1|||5s|
|๐ข [org.apache.pulsar.functions.worker.PulsarFunctionE2ESecurityTest](#r0s130)|2|||28s|
|๐ข [org.apache.pulsar.functions.worker.PulsarFunctionPublishTest](#r0s131)|3|||42s|
|๐ข [org.apache.pulsar.functions.worker.PulsarFunctionTlsTest](#r0s132)|1|||12s|
|๐ข [org.apache.pulsar.io.PulsarFunctionTlsTest](#r0s133)|1|||30s|
|๐ข [org.apache.pulsar.proxy.server.AdminProxyHandlerTest](#r0s134)|1|||474ms|
|๐ข [org.apache.pulsar.proxy.server.AuthedAdminProxyHandlerTest](#r0s135)|1|||2s|
|๐ข [org.apache.pulsar.proxy.server.FunctionWorkerRoutingTest](#r0s136)|1|||10ms|
|๐ข [org.apache.pulsar.proxy.server.ProxyAdditionalServletTest](#r0s137)|1|||125ms|
|๐ข [org.apache.pulsar.proxy.server.ProxyAuthenticatedProducerConsumerTest](#r0s138)|1|||2s|
|๐ข [org.apache.pulsar.proxy.server.ProxyAuthenticationTest](#r0s139)|1|||17s|
|๐ข [org.apache.pulsar.proxy.server.ProxyConnectionThrottlingTest](#r0s140)|1|||2s|
|๐ข [org.apache.pulsar.proxy.server.ProxyEnableHAProxyProtocolTest](#r0s141)|1|||511ms|
|๐ข [org.apache.pulsar.proxy.server.ProxyForwardAuthDataTest](#r0s142)|1|||32s|
|๐ข [org.apache.pulsar.proxy.server.ProxyIsAHttpProxyTest](#r0s143)|10|||2s|
|๐ข [org.apache.pulsar.proxy.server.ProxyKeyStoreTlsTestWithAuth](#r0s144)|3|||7s|
|๐ข [org.apache.pulsar.proxy.server.ProxyKeyStoreTlsTestWithoutAuth](#r0s145)|3|||7s|
|๐ข [org.apache.pulsar.proxy.server.ProxyLookupThrottlingTest](#r0s146)|1|||3s|
|๐ข [org.apache.pulsar.proxy.server.ProxyParserTest](#r0s147)|5|||1s|
|๐ข [org.apache.pulsar.proxy.server.ProxyRolesEnforcementTest](#r0s148)|1|||10s|
|๐ข [org.apache.pulsar.proxy.server.ProxyStatsTest](#r0s149)|3|||533ms|
|๐ข [org.apache.pulsar.proxy.server.ProxyTest](#r0s150)|6|||3s|
|๐ข [org.apache.pulsar.proxy.server.ProxyTlsTest](#r0s151)|2|||414ms|
|๐ข [org.apache.pulsar.proxy.server.ProxyTlsTestWithAuth](#r0s152)|1|||4ms|
|๐ข [org.apache.pulsar.proxy.server.ProxyWithAuthorizationNegTest](#r0s153)|1|||2s|
|๐ข [org.apache.pulsar.proxy.server.ProxyWithAuthorizationTest](#r0s154)|13|||33s|
|๐ข [org.apache.pulsar.proxy.server.ProxyWithoutServiceDiscoveryTest](#r0s155)|1|||2s|
|๐ข [org.apache.pulsar.proxy.server.SuperUserAuthedAdminProxyHandlerTest](#r0s156)|3|||8s|
|๐ข [org.apache.pulsar.proxy.server.UnauthedAdminProxyHandlerTest](#r0s157)|2|||114ms|
|๐ข [org.apache.pulsar.PulsarBrokerStarterTest](#r0s158)|9|||591ms|
|๐ข [org.apache.pulsar.schema.compatibility.SchemaCompatibilityCheckTest](#r0s159)|23|||107s|
|๐ข [org.apache.pulsar.schema.PartitionedTopicSchemaTest](#r0s160)|1|||29s|
|๐ข [org.apache.pulsar.schema.SchemaTest](#r0s161)|3|||31s|
|๐ข [org.apache.pulsar.stats.client.PulsarBrokerStatsClientTest](#r0s162)|2|||41s|
|๐ข [org.apache.pulsar.tests.EnumValuesDataProviderTest](#r0s163)|6|||23ms|
|๐ข [org.apache.pulsar.tests.TestRetrySupportBeforeMethodRetryTest](#r0s164)|1||4|36ms|
|๐ข [org.apache.pulsar.tests.TestRetrySupportRetryTest](#r0s165)|1||4|27ms|
|๐ข [org.apache.pulsar.tests.TestRetrySupportSuccessTest](#r0s166)|3|||1ms|
|๐ข [org.apache.pulsar.tests.ThreadDumpUtilTest](#r0s167)|2|||17ms|
|๐ข [org.apache.pulsar.utils.SimpleTextOutputStreamTest](#r0s168)|4|||50ms|
|๐ข [org.apache.pulsar.utils.StatsOutputStreamTest](#r0s169)|6|||59ms|
|๐ข [org.apache.pulsar.websocket.proxy.ProxyAuthenticationTest](#r0s170)|4|||29s|
|๐ข [org.apache.pulsar.websocket.proxy.ProxyAuthorizationTest](#r0s171)|1|||1s|
|๐ข [org.apache.pulsar.websocket.proxy.ProxyConfigurationTest](#r0s172)|2|||9s|
|๐ข [org.apache.pulsar.websocket.proxy.ProxyPublishConsumeTlsTest](#r0s173)|1|||11s|
|๐ข [org.apache.pulsar.websocket.proxy.ProxyPublishConsumeWithoutZKTest](#r0s174)|1|||7s|
|๐ข [org.apache.pulsar.websocket.proxy.v1.V1_ProxyAuthenticationTest](#r0s175)|4|||30s|
### ๐ดย org.apache.pulsar.AddMissingPatchVersionTest
```
โช testVersionStrings
๐ด testVersionStrings
java.lang.AssertionError: expected [1.2.1] but found [1.2.0]
```
### ๐ขย org.apache.pulsar.broker.admin.AdminApiOffloadTest
```
๐ข testOffloadPoliciesAppliedApi
๐ข testOffloadV2
๐ข testTopicLevelOffloadNonPartitioned
๐ข testTopicLevelOffloadPartitioned
๐ข testOffloadV1
๐ข testOffloadPolicies
๐ข testOffloadPoliciesApi
```
### ๐ขย org.apache.pulsar.broker.auth.AuthenticationServiceTest
```
๐ข testAuthentication
๐ข testAuthenticationHttp
```
### ๐ขย org.apache.pulsar.broker.auth.AuthLogsTest
```
๐ข httpEndpoint
๐ข binaryEndpoint
```
### ๐ขย org.apache.pulsar.broker.auth.AuthorizationTest
```
๐ข simple
```
### ๐ขย org.apache.pulsar.broker.lookup.http.HttpTopicLookupv2Test
```
๐ข crossColoLookup
๐ข testNotEnoughLookupPermits
๐ข testValidateReplicationSettingsOnNamespace
๐ข testDataPojo
```
### ๐ขย org.apache.pulsar.broker.namespace.NamespaceCreateBundlesTest
```
๐ข testCreateNamespaceWithDefaultBundles
๐ข testSplitBundleUpdatesLocalPoliciesWithoutOverwriting
```
### ๐ขย org.apache.pulsar.broker.namespace.NamespaceOwnershipListenerTests
```
๐ข testGetAllPartitions
๐ข testNamespaceBundleOwnershipListener
```
### ๐ขย org.apache.pulsar.broker.namespace.NamespaceServiceTest
```
๐ข testSplitMapWithRefreshedStatMap
๐ข testRemoveOwnershipNamespaceBundle
๐ข testIsServiceUnitDisabled
๐ข testLoadReportDeserialize
๐ข testCreateLookupResult
๐ข testUnloadNamespaceBundleWithStuckTopic
๐ข testUnloadNamespaceBundleFailure
๐ข testSplitAndOwnBundles
๐ข testCreateNamespaceWithDefaultNumberOfBundles
๐ข testRemoveOwnershipAndSplitBundle
```
### ๐ขย org.apache.pulsar.broker.namespace.NamespaceUnloadingTest
```
๐ข testUnloadNotLoadedNamespace
๐ข testUnloadPartiallyLoadedNamespace
```
### ๐ขย org.apache.pulsar.broker.namespace.OwnerShipCacheForCurrentServerTest
```
๐ข testOwnershipForCurrentServer
```
### ๐ขย org.apache.pulsar.broker.namespace.OwnershipCacheTest
```
๐ข testGetOwnedServiceUnits
๐ข testRemoveOwnership
๐ข testGetOwnedServiceUnit
๐ข testGetOrSetOwner
๐ข testConstructor
๐ข testGetOwner
๐ข testDisableOwnership
๐ข testReestablishOwnership
```
### ๐ขย org.apache.pulsar.broker.protocol.ProtocolHandlersTest
```
๐ข testStart
๐ข testGetProtocol
๐ข testNewChannelInitializersSuccess
๐ข testInitialize
๐ข testNewChannelInitializersOverlapped
๐ข testGetProtocolDataToAdvertise
```
### ๐ขย org.apache.pulsar.broker.protocol.ProtocolHandlerUtilsTest
```
๐ข testLoadProtocolHandler
๐ข testLoadProtocolHandlerBlankHandlerClass
๐ข testLoadProtocolHandlerWrongHandlerClass
```
### ๐ขย org.apache.pulsar.broker.protocol.ProtocolHandlerWithClassLoaderTest
```
๐ข testWrapper
```
### ๐ขย org.apache.pulsar.broker.PulsarServiceTest
```
๐ข testGetWorkerService
๐ข testGetWorkerServiceException
```
### ๐ขย org.apache.pulsar.broker.service.MessagePublishBufferThrottleTest
```
๐ข testMessagePublishBufferThrottleEnable
๐ข testBlockByPublishRateLimiting
๐ข testMessagePublishBufferThrottleDisabled
```
### ๐ขย org.apache.pulsar.broker.service.ReplicatorTest
```
๐ข testResumptionAfterBacklogRelaxed
๐ข testReplicationOverrides
๐ข testResetCursorNotFail
๐ข testUpdateGlobalTopicPartition
๐ข testReplication
๐ข testReplicatorOnPartitionedTopic
๐ข testConcurrentReplicator
๐ข testTopicReplicatedAndProducerCreate
๐ข testDeleteReplicatorFailure
๐ข testReplicatorOnPartitionedTopic
๐ข testReplicationForBatchMessages
๐ข testReplicatorClearBacklog
๐ข verifyChecksumAfterReplication
๐ข testCloseReplicatorStartProducer
๐ข activeBrokerParse
๐ข testReplicatePeekAndSkip
๐ข testReplication
๐ข testReplicatedCluster
๐ข testTopicReplicatedAndProducerCreate
๐ข testConfigChange
๐ข testFailures
๐ข testReplicatorProducerClosing
```
### ๐ขย org.apache.pulsar.broker.service.TopicOwnerTest
```
๐ข testReleaseOwnershipWithZookeeperDisconnectedBeforeOwnershipNodeDeleted
๐ข testAcquireOwnershipWithZookeeperDisconnectedAfterOwnershipNodeCreated
๐ข testConnectToInvalidateBundleCacheBroker
๐ข testAcquireOwnershipWithZookeeperDisconnectedBeforeOwnershipNodeCreated
๐ข testLookupPartitionedTopic
๐ข testListNonPersistentTopic
๐ข testReleaseOwnershipWithZookeeperDisconnectedAfterOwnershipNodeDeleted
๐ข testReestablishOwnershipAfterInvalidateCache
```
### ๐ขย org.apache.pulsar.broker.SLAMonitoringTest
```
๐ข testOwnedNamespaces
๐ข testOwnershipAfterSetup
๐ข testUnloadIfBrokerCrashes
๐ข testOwnershipViaAdminAfterSetup
```
### ๐ขย org.apache.pulsar.broker.stats.BookieClientsStatsGeneratorTest
```
๐ข testJvmDirectMemoryUsedMetric
๐ข testBookieClientStatsGenerator
```
### ๐ขย org.apache.pulsar.broker.stats.ConsumerStatsTest
```
๐ข testAckStatsOnPartitionedTopicForExclusiveSubscription
๐ข testConsumerStatsOnZeroMaxUnackedMessagesPerConsumer
๐ข testUpdateStatsForActiveConsumerAndSubscription
```
### ๐ขย org.apache.pulsar.broker.stats.ManagedCursorMetricsTest
```
๐ข testManagedCursorMetrics
```
### ๐ขย org.apache.pulsar.broker.stats.ManagedLedgerMetricsTest
```
๐ข testManagedLedgerMetrics
```
### ๐ขย org.apache.pulsar.broker.stats.prometheus.AggregatedNamespaceStatsTest
```
๐ข testSimpleAggregation
```
### ๐ขย org.apache.pulsar.broker.stats.PrometheusMetricsTest
```
๐ข testPerTopicStats
๐ข testAuthMetrics
๐ข testPerTopicExpiredStat
๐ข testPerProducerStats
๐ข testMetricsTopicCount
๐ข testManagedLedgerBookieClientStats
๐ข testDuplicateMetricTypeDefinitions
๐ข testExpiringTokenMetrics
๐ข testPerConsumerStats
๐ข testPerNamespaceStats
๐ข testManagedCursorPersistStats
๐ข testDuplicateMetricTypeDefinitions
๐ข testExpiredTokenMetrics
๐ข testManagedLedgerCacheStats
๐ข testManagedLedgerStats
```
### ๐ขย org.apache.pulsar.broker.stats.SubscriptionStatsTest
```
๐ข testConsumersAfterMarkDelete
๐ข testNonContiguousDeletedMessagesRanges
```
### ๐ขย org.apache.pulsar.broker.systopic.NamespaceEventsSystemTopicServiceTest
```
๐ข testSendAndReceiveNamespaceEvents
```
### ๐ขย org.apache.pulsar.broker.transaction.buffer.InMemTransactionBufferReaderTest
```
๐ข testCloseReleaseAllEntries
๐ข testInvalidNumEntriesArgument
๐ข testEndOfTransactionException
```
### ๐ขย org.apache.pulsar.broker.transaction.buffer.TransactionBufferClientTest
```
๐ข testAbortOnTopic
๐ข testAbortOnSubscription
๐ข testCommitOnTopic
๐ข testCommitOnSubscription
```
### ๐ขย org.apache.pulsar.broker.transaction.buffer.TransactionBufferTest
```
๐ข testOpenReaderOnNonExistentTxn
๐ข testAbortCommittedTxn
๐ข testAbortTxn
๐ข testAbortNonExistentTxn
๐ข testCommitNonExistentTxn
๐ข testCommitTxn
๐ข testOpenReaderOnAnOpenTxn
```
### ๐ขย org.apache.pulsar.broker.transaction.buffer.TransactionEntryImplTest
```
๐ข testCloseShouldReleaseBuffer
```
### ๐ขย org.apache.pulsar.broker.transaction.buffer.TransactionLowWaterMarkTest
```
๐ข testTransactionBufferLowWaterMark
๐ข testPendingAckLowWaterMark
```
### ๐ขย org.apache.pulsar.broker.transaction.buffer.TransactionStablePositionTest
```
๐ข commitTxnTest
๐ข abortTxnTest
โช commitTxnTest
```
### ๐ขย org.apache.pulsar.broker.transaction.coordinator.TransactionCoordinatorClientTest
```
๐ข testClientStart
๐ข testCommitAndAbort
๐ข testNewTxn
```
### ๐ขย org.apache.pulsar.broker.transaction.coordinator.TransactionMetaStoreAssignmentTest
```
๐ข testTransactionMetaStoreAssignAndFailover
```
### ๐ขย org.apache.pulsar.broker.transaction.pendingack.PendingAckInMemoryDeleteTest
```
โช txnAckTestNoBatchAndSharedSubMemoryDeleteTest
๐ข txnAckTestNoBatchAndSharedSubMemoryDeleteTest
๐ข txnAckTestBatchAndSharedSubMemoryDeleteTest
```
### ๐ขย org.apache.pulsar.broker.transaction.TransactionConsumeTest
```
๐ข noSortedTest
๐ข sortedTest
```
### ๐ขย org.apache.pulsar.broker.web.RestExceptionTest
```
๐ข testRestException
๐ข testWebApplicationException
๐ข testOtherException
```
### ๐ขย org.apache.pulsar.broker.web.WebServiceTest
```
๐ข testTlsAuthDisallowInsecure
๐ข testBrokerReady
๐ข testDefaultClientVersion
๐ข testTlsEnabled
๐ข testTlsAuthAllowInsecure
๐ข testSplitPath
๐ข testMaxRequestSize
๐ข testTlsDisabled
๐ข testRateLimiting
```
### ๐ขย org.apache.pulsar.client.impl.AdminApiKeyStoreTlsAuthTest
```
๐ข testAuthorizedUserAsOriginalPrincipal
๐ข testSuperUserCantListNamespaces
๐ข testPersistentList
๐ข testSuperUserCanListTenants
```
### ๐ขย org.apache.pulsar.client.impl.BatchMessageIdImplSerializationTest
```
๐ข testSerializationEmpty
๐ข testSerialization1
๐ข testSerializationNull
๐ข testSerialization2
```
### ๐ขย org.apache.pulsar.client.impl.BatchMessageIndexAckDisableTest
```
๐ข testBatchMessageIndexAckForExclusiveSubscription
๐ข testBatchMessageIndexAckForSharedSubscription
๐ข testBatchMessageIndexAckForExclusiveSubscription
๐ข testBatchMessageIndexAckForSharedSubscription
```
### ๐ขย org.apache.pulsar.client.impl.BatchMessageIndexAckTest
```
๐ข testBatchMessageIndexAckForSharedSubscription
๐ข testBatchMessageIndexAckForSharedSubscription
๐ข testDoNotRecycleAckSetMultipleTimes
๐ข testBatchMessageIndexAckForExclusiveSubscription
๐ข testBatchMessageIndexAckForExclusiveSubscription
```
### ๐ขย org.apache.pulsar.client.impl.BrokerClientIntegrationTest
```
๐ข testDisconnectClientWithoutClosingConnection
๐ข testResetCursor
๐ข testResetCursor
๐ข testCloseBrokerService
๐ข testUnsupportedBatchMessageConsumer
๐ข testAvroSchemaProducerConsumerWithSpecifiedReaderAndWriter
๐ข testJsonSchemaProducerConsumerWithSpecifiedReaderAndWriter
๐ข testOperationTimeout
๐ข testCleanProducer
๐ข testUnsupportedBatchMessageConsumer
๐ข testCloseConnectionOnBrokerRejectedRequest
๐ข testAddEntryOperationTimeout
๐ข testInvalidDynamicConfiguration
๐ข testMaxConcurrentTopicLoading
๐ข testCloseConnectionOnInternalServerError
```
### ๐ขย org.apache.pulsar.client.impl.CompactedOutBatchMessageTest
```
๐ข testCompactedOutMessages
```
### ๐ขย org.apache.pulsar.client.impl.ConsumerAckResponseTest
```
๐ข testAckResponse
```
### ๐ขย org.apache.pulsar.client.impl.ConsumerConfigurationTest
```
๐ข testReadCompactNonPersistentExclusive
๐ข testReadCompactPersistentExclusive
๐ข testReadCompactPersistentFailover
๐ข testReadCompactPersistentShared
```
### ๐ขย org.apache.pulsar.client.impl.ConsumerDedupPermitsUpdate
```
๐ข testConsumerDedup
๐ข testConsumerDedup
๐ข testConsumerDedup
๐ข testConsumerDedup
๐ข testConsumerDedup
๐ข testConsumerDedup
๐ข testConsumerDedup
```
### ๐ขย org.apache.pulsar.client.impl.ConsumerUnsubscribeTest
```
๐ข testConsumerUnsubscribeReference
```
### ๐ขย org.apache.pulsar.client.impl.KeyStoreTlsProducerConsumerTestWithAuth
```
๐ข testTlsClientAuthOverHTTPProtocol
๐ข testTlsClientAuthOverBinaryProtocol
๐ข testTlsLargeSizeMessage
```
### ๐ขย org.apache.pulsar.client.impl.KeyStoreTlsProducerConsumerTestWithoutAuth
```
๐ข testTlsClientAuthOverHTTPProtocol
๐ข testTlsClientAuthOverBinaryProtocol
๐ข testTlsLargeSizeMessage
```
### ๐ขย org.apache.pulsar.client.impl.KeyStoreTlsTest
```
๐ข testValidate
```
### ๐ขย org.apache.pulsar.client.impl.MessageChecksumTest
```
๐ข testChecksumCompatibilityInMixedVersionBrokerCluster
๐ข testTamperingMessageIsDetected
๐ข testChecksumCompatibilityInMixedVersionBrokerCluster
```
### ๐ขย org.apache.pulsar.client.impl.MessageChunkingTest
```
๐ข testPublishWithFailure
๐ข testInvalidUseCaseForChunking
๐ข testLargeMessage
๐ข testExpireIncompleteChunkMessage
๐ข testInvalidConfig
๐ข testLargeMessageAckTimeOut
๐ข testLargeMessageAckTimeOut
๐ข testLargeMessage
โช testMaxPendingChunkMessages
```
### ๐ขย org.apache.pulsar.client.impl.MessageParserTest
```
๐ข testWithoutBatches
๐ข testWithBatches
```
### ๐ขย org.apache.pulsar.client.impl.MultiTopicsReaderTest
```
๐ข testReadMessageWithBatchingWithMessageInclusive
๐ข testKeyHashRangeReader
๐ข testRemoveSubscriptionForReaderNeedRemoveCursor
๐ข testReadMessageWithBatching
๐ข testReadMessageWithoutBatchingWithMessageInclusive
๐ข testMultiReaderSeek
๐ข testReadMessageWithoutBatching
๐ข testReaderWithTimeLong
```
### ๐ขย org.apache.pulsar.client.impl.NegativeAcksTest
```
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
๐ข testNegativeAcks
```
### ๐ขย org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest
```
๐ข testStartEmptyPatternConsumer
๐ข testBinaryProtoToGetTopicsOfNamespaceAll
๐ข testPatternTopicsSubscribeWithBuilderFail
๐ข testPubRateOnNonPersistent
๐ข testTopicDeletion
๐ข testAutoUnbubscribePatternConsumer
๐ข testTopicsPatternFilter
๐ข testBinaryProtoToGetTopicsOfNamespaceNonPersistent
๐ข testBinaryProtoToGetTopicsOfNamespacePersistent
๐ข testTopicsListMinus
๐ข testAutoSubscribePatternConsumer
```
### ๐ขย org.apache.pulsar.client.impl.PerMessageUnAcknowledgedRedeliveryTest
```
๐ข testSharedAckedNormalTopic
๐ข testUnAckedMessageTrackerSize
๐ข testSharedAckedPartitionedTopic
๐ข testExclusiveAckedNormalTopic
๐ข testFailoverAckedNormalTopic
```
### ๐ขย org.apache.pulsar.client.impl.PulsarMultiHostClientTest
```
๐ข testMultiHostUrlRetrySuccess
๐ข testGetPartitionedTopicDataTimeout
๐ข testGetPartitionedTopicMetaData
```
### ๐ขย org.apache.pulsar.client.impl.RawMessageSerDeserTest
```
๐ข testSerializationAndDeserialization
```
### ๐ขย org.apache.pulsar.client.impl.SchemaDeleteTest
```
๐ข createTopicDeleteTopicCreateTopic
```
### ๐ขย org.apache.pulsar.client.impl.SequenceIdWithErrorTest
```
๐ข testCheckSequenceId
๐ข testDeleteTopicWithMissingData
๐ข testTopicWithWildCardChar
โช testCrashBrokerWithoutCursorLedgerLeak
โช testSkipCorruptDataLedger
```
### ๐ขย org.apache.pulsar.client.impl.TopicDoesNotExistsTest
```
๐ข testCreateConsumerOnNotExistsTopic
๐ข testCreateProducerOnNotExistsTopic
```
### ๐ขย org.apache.pulsar.client.impl.TopicFromMessageTest
```
๐ข testSingleTopicConsumerNoBatchFullName
๐ข testMultiTopicConsumerBatchShortName
๐ข testSingleTopicConsumerNoBatchShortName
๐ข testMultiTopicConsumerNoBatchShortName
๐ข testSingleTopicConsumerBatchShortName
```
### ๐ขย org.apache.pulsar.client.impl.TopicsConsumerImplTest
```
๐ข testTopicAutoUpdatePartitions
๐ข testDifferentTopicsNameSubscribe
๐ข testGetLastMessageId
๐ข testConsumerUnackedRedelivery
๐ข testSubscriptionMustCompleteWhenOperationTimeoutOnMultipleTopics
๐ข testConsumerDistributionInFailoverSubscriptionWhenUpdatePartitions
๐ข multiTopicsInDifferentNameSpace
๐ข testDefaultBacklogTTL
๐ข testGetConsumersAndGetTopics
๐ข testSubscribeUnsubscribeSingleTopic
๐ข testResubscribeSameTopic
๐ข testSyncProducerAndConsumer
๐ข testPartitionsUpdatesForMultipleTopics
๐ข testTopicsNameSubscribeWithBuilderFail
๐ข testMultiTopicsMessageListener
๐ข testTopicNameValid
๐ข testAsyncConsumer
```
### ๐ขย org.apache.pulsar.client.impl.UnAcknowledgedMessagesTimeoutTest
```
๐ข testCheckUnAcknowledgedMessageTimer
๐ข testExclusiveSingleAckedNormalTopic
๐ข testFailoverSingleAckedPartitionedTopic
๐ข testSharedSingleAckedPartitionedTopic
๐ข testAckTimeoutMinValue
๐ข testExclusiveCumulativeAckedNormalTopic
๐ข testSingleMessageBatch
```
### ๐ขย org.apache.pulsar.client.impl.ZeroQueueSizeTest
```
๐ข zeroQueueSizeSharedSubscription
๐ข testPauseAndResume
๐ข testZeroQueueSizeMessageRedeliveryForAsyncReceive
๐ข zeroQueueSizeConsumerListener
๐ข zeroQueueSizeFailoverSubscription
๐ข validQueueSizeConfig
๐ข zeroQueueSizeNormalConsumer
๐ข zeroQueueSizeReceieveAsyncInCompatibility
๐ข InvalidQueueSizeConfig
๐ข testZeroQueueSizeMessageRedeliveryForListener
๐ข testZeroQueueSizeMessageRedelivery
๐ข zeroQueueSizePartitionedTopicInCompatibility
๐ข testFailedZeroQueueSizeBatchMessage
๐ข testPauseAndResumeWithUnloading
```
### ๐ขย org.apache.pulsar.common.api.raw.RawMessageImplTest
```
๐ข testGetProperties
```
### ๐ขย org.apache.pulsar.common.compression.CommandsTest
```
๐ข testChecksumSendCommand
```
### ๐ขย org.apache.pulsar.common.compression.CompressorCodecBackwardCompatTest
```
๐ข testCompressDecompress
๐ข testCompressDecompress
๐ข testCompressDecompress
๐ข testCompressDecompress
๐ข testCompressDecompress
๐ข testCompressDecompress
```
### ๐ขย org.apache.pulsar.common.compression.CompressorCodecTest
```
๐ข testCompressDecompress
๐ข testMultpileUsages
๐ข testMultpileUsages
๐ข testCompressDecompress
๐ข testMultpileUsages
๐ข testCompressDecompress
๐ข testMultpileUsages
๐ข testCompressDecompress
๐ข testDecompressFromSampleBuffer
๐ข testDecompressReadonlyByteBuf
๐ข testDecompressReadonlyByteBuf
๐ข testCodecProvider
๐ข testEmptyInput
๐ข testEmptyInput
๐ข testCompressDecompress
๐ข testCodecProvider
๐ข testDecompressFromSampleBuffer
๐ข testMultpileUsages
๐ข testCodecProvider
๐ข testEmptyInput
๐ข testDecompressReadonlyByteBuf
๐ข testCompressDecompress
๐ข testDecompressReadonlyByteBuf
๐ข testCompressDecompress
๐ข testCompressDecompress
๐ข testMultpileUsages
๐ข testEmptyInput
๐ข testDecompressReadonlyByteBuf
๐ข testDecompressFromSampleBuffer
๐ข testDecompressFromSampleBuffer
๐ข testDecompressFromSampleBuffer
๐ข testDecompressReadonlyByteBuf
๐ข testDecompressReadonlyByteBuf
๐ข testMultpileUsages
๐ข testCompressDecompress
๐ข testCodecProvider
๐ข testMultpileUsages
๐ข testCompressDecompress
๐ข testMultpileUsages
๐ข testDecompressReadonlyByteBuf
๐ข testEmptyInput
๐ข testCodecProvider
๐ข testDecompressReadonlyByteBuf
๐ข testDecompressReadonlyByteBuf
๐ข testMultpileUsages
```
### ๐ขย org.apache.pulsar.common.compression.Crc32cChecksumTest
```
๐ข testCrc32cHardware
๐ข testCrc32cDirectMemoryHardware
๐ข testCrc32c
๐ข testCrc32cSoftware
๐ข testCrc32cIncremental
๐ข testCrc32cIncrementalUsingProvider
```
### ๐ขย org.apache.pulsar.common.lookup.data.LookupDataTest
```
๐ข testLoadReportSerialization
๐ข testUrlEncoder
๐ข serializeToJsonTest
๐ข withConstructor
```
### ๐ขย org.apache.pulsar.common.naming.MetadataTests
```
๐ข testInvalidMetadata
๐ข testValidMetadata
```
### ๐ขย org.apache.pulsar.common.naming.NamespaceBundlesTest
```
๐ข testConstructor
๐ข testSplitBundleInTwo
๐ข testsplitBundles
๐ข testFindBundle
๐ข testSplitBundleByFixBoundary
```
### ๐ขย org.apache.pulsar.common.naming.NamespaceBundleTest
```
๐ข testIncludes
๐ข testGetBundle
๐ข testCompareTo
๐ข testConstructor
๐ข testToString
๐ข testEquals
```
### ๐ขย org.apache.pulsar.common.naming.NamespaceNameTest
```
๐ข namespace
๐ข testNewScheme
```
### ๐ขย org.apache.pulsar.common.naming.ServiceConfigurationTest
```
๐ข testOptionalSettingPresent
๐ข testOptionalSettingEmpty
๐ข testInit
๐ข testInitFailure
```
### ๐ขย org.apache.pulsar.common.naming.TopicNameTest
```
๐ข testShortTopicName
๐ข topic
๐ข testTopicNameWithoutCluster
๐ข testDecodeEncode
```
### ๐ขย org.apache.pulsar.common.net.ServiceURITest
```
๐ข testEmptyServiceUriString
๐ข testMultipleHostsSemiColon
๐ข testInvalidServiceUris
๐ข testMultipleHostsWithoutHttpPorts
๐ข testRootPath
๐ข testMultipleHostsMixedPorts
๐ข testMultipleHostsWithoutPulsarTlsPorts
๐ข testUserInfoWithMultipleHosts
๐ข testMultipleHostsComma
๐ข testMultipleHostsMixed
๐ข testUserInfo
๐ข testIpv6UriWithoutPulsarPort
๐ข testMultiIpv6Uri
๐ข testMultiIpv6UriWithoutPulsarPort
๐ข testEmptyPath
๐ข testNullServiceUriString
๐ข testNullServiceUriInstance
๐ข testMissingServiceName
๐ข testMultipleHostsWithoutHttpsPorts
๐ข testMultipleHostsWithoutPulsarPorts
๐ข testIpv6Uri
```
### ๐ขย org.apache.pulsar.common.policies.data.AutoFailoverPolicyDataTest
```
๐ข testAutoFailoverPolicyData
```
### ๐ขย org.apache.pulsar.common.policies.data.AutoFailoverPolicyTypeTest
```
๐ข testAutoFailoverPolicyType
```
### ๐ขย org.apache.pulsar.common.policies.data.AutoTopicCreationOverrideTest
```
๐ข testInvalidTopicType
๐ข testNumPartitionsTooLow
๐ข testNumPartitionsNotSet
๐ข testValidOverrideNonPartitioned
๐ข testNumPartitionsOnNonPartitioned
๐ข testValidOverridePartitioned
```
### ๐ขย org.apache.pulsar.common.policies.data.BacklogQuotaTest
```
๐ข testBacklogQuotaIdentity
```
### ๐ขย org.apache.pulsar.common.policies.data.ClusterDataTest
```
๐ข simple
```
### ๐ขย org.apache.pulsar.common.policies.data.ConsumerStatsTest
```
๐ข testConsumerStats
```
### ๐ขย org.apache.pulsar.common.policies.data.EnsemblePlacementPolicyConfigTest
```
๐ข testDecodeFailed
๐ข testEncodeDecodeSuccessfully
```
### ๐ขย org.apache.pulsar.common.policies.data.LocalPolicesTest
```
๐ข testLocalPolices
```
### ๐ขย org.apache.pulsar.common.policies.data.NamespaceIsolationDataTest
```
๐ข testNamespaceIsolationData
```
### ๐ขย org.apache.pulsar.common.policies.data.NamespaceOwnershipStatusTest
```
๐ข testSerialization
```
### ๐ขย org.apache.pulsar.common.policies.data.OffloadPoliciesTest
```
๐ข testGcsConfiguration
๐ข mergeTest
๐ข compatibleWithConfigFileTest
๐ข testCreateByProperties
๐ข testS3Configuration
๐ข oldPoliciesCompatibleTest
```
### ๐ขย org.apache.pulsar.common.policies.data.PartitionedTopicStatsTest
```
๐ข testPartitionedTopicStats
```
### ๐ขย org.apache.pulsar.common.policies.data.PersistencePoliciesTest
```
๐ข testPersistencePolicies
```
### ๐ขย org.apache.pulsar.common.policies.data.PersistentOfflineTopicStatsTest
```
๐ข testPersistentOfflineTopicStats
```
### ๐ขย org.apache.pulsar.common.policies.data.PersistentTopicStatsTest
```
๐ข testPersistentTopicStatsAggregation
๐ข testPersistentTopicStats
```
### ๐ขย org.apache.pulsar.common.policies.data.PoliciesDataTest
```
๐ข propertyAdmin
๐ข policies
๐ข bundlesData
๐ข bundlesPolicies
```
### ๐ขย org.apache.pulsar.common.policies.data.PublisherStatsTest
```
๐ข testPublisherStats
๐ข testPublisherStatsAggregation
```
### ๐ขย org.apache.pulsar.common.policies.data.ReplicatorStatsTest
```
๐ข testReplicatorStatsAdd
๐ข testReplicatorStatsNull
```
### ๐ขย org.apache.pulsar.common.policies.data.ResourceQuotaTest
```
๐ข testResourceQuotaDefault
๐ข testResourceQuotaEqual
```
### ๐ขย org.apache.pulsar.common.policies.data.RetentionPolicesTest
```
๐ข testRetentionPolices
```
### ๐ขย org.apache.pulsar.common.policies.impl.AutoFailoverPolicyFactoryTest
```
๐ข testAutoFailoverPolicyFactory
```
### ๐ขย org.apache.pulsar.common.policies.impl.MinAvailablePolicyTest
```
๐ข testMinAvailablePolicty
```
### ๐ขย org.apache.pulsar.common.policies.impl.NamespaceIsolationPoliciesTest
```
๐ข testBrokerAssignment
๐ข testGetNamespaceIsolationPolicyByName
๐ข testDeletePolicy
๐ข testSetPolicy
๐ข testJsonSerialization
๐ข testDefaultConstructor
๐ข testGetNamespaceIsolationPolicyByNamespace
```
### ๐ขย org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImplTest
```
๐ข testFindBrokers
๐ข testGetSecondaryBrokers
๐ข testShouldFailover
๐ข testGetPrimaryBrokers
๐ข testGetAvailablePrimaryBrokers
๐ข testConstructor
๐ข testIsPrimaryOrSecondaryBroker
```
### ๐ขย org.apache.pulsar.common.protocol.ByteBufPairTest
```
๐ข testEncoder
๐ข testDoubleByteBuf
```
### ๐ขย org.apache.pulsar.common.protocol.CommandUtilsTests
```
๐ข testSkipBrokerEntryMetadata
๐ข testPeekBrokerEntryMetadata
๐ข testParseBrokerEntryMetadata
๐ข testMetadataFromCommandSubscribe
๐ข testMetadataFromCommandProducer
๐ข testAddBrokerEntryMetadata
๐ข testByteBufComposite
```
### ๐ขย org.apache.pulsar.common.protocol.MarkersTest
```
๐ข testSnapshot
๐ข testTxnAbortMarker
๐ข testUpdate
๐ข testTxnCommitMarker
๐ข testSnapshotRequest
๐ข testSnapshotResponse
```
### ๐ขย org.apache.pulsar.common.protocol.PulsarDecoderTest
```
๐ข testChannelRead
```
### ๐ขย org.apache.pulsar.common.stats.JvmDefaultGCMetricsLoggerTest
```
๐ข testInvokeJVMInternals
```
### ๐ขย org.apache.pulsar.common.util.collections.BitSetRecyclableRecyclableTest
```
๐ข testResetWords
๐ข testRecycle
```
### ๐ขย org.apache.pulsar.common.util.collections.ConcurrentBitSetRecyclableTest
```
๐ข testRecycle
๐ข testGenerateByBitSet
```
### ๐ขย org.apache.pulsar.common.util.collections.ConcurrentLongHashMapTest
```
๐ข testRehashingWithDeletes
๐ข concurrentInsertionsAndReads
๐ข testRemove
๐ข testRehashing
๐ข simpleInsertions
๐ข testComputeIfAbsent
๐ข testConstructor
๐ข testPutIfAbsent
๐ข testIteration
๐ข testHashConflictWithDeletion
๐ข concurrentInsertions
๐ข stressConcurrentInsertionsAndReads
๐ข testNegativeUsedBucketCount
```
### ๐ขย org.apache.pulsar.common.util.collections.ConcurrentLongPairSetTest
```
๐ข concurrentInsertionsAndReads
๐ข testEqualsObjects
๐ข testIfRemoval
๐ข testRehashing
๐ข testToString
๐ข testRemove
๐ข testItems
๐ข testRehashingWithDeletes
๐ข testHashConflictWithDeletion
๐ข testIteration
๐ข simpleInsertions
๐ข testRehashingRemoval
๐ข testRemoval
๐ข testConstructor
๐ข concurrentInsertions
```
### ๐ขย org.apache.pulsar.common.util.collections.ConcurrentOpenHashMapTest
```
๐ข testRemove
๐ข simpleInsertions
๐ข testPutIfAbsent
๐ข concurrentInsertions
๐ข testHashConflictWithDeletion
๐ข testRehashingWithDeletes
๐ข testComputeIfAbsent
๐ข testRehashing
๐ข testIteration
๐ข testEqualsKeys
๐ข concurrentInsertionsAndReads
๐ข testConstructor
```
### ๐ขย org.apache.pulsar.common.util.collections.ConcurrentOpenHashSetTest
```
๐ข concurrentInsertions
๐ข testRehashing
๐ข testRemoval
๐ข testEqualsObjects
๐ข testHashConflictWithDeletion
๐ข testConstructor
๐ข concurrentInsertionsAndReads
๐ข testIteration
๐ข simpleInsertions
๐ข testRehashingWithDeletes
๐ข testRemove
```
### ๐ขย org.apache.pulsar.common.util.collections.ConcurrentOpenLongPairRangeSetTest
```
๐ข testAddForDifferentKey
๐ข testToString
๐ข testCacheFlagConflict
๐ข testDeleteWithLeastMost
๐ข testDeleteForDifferentKey
๐ข testLastRange
๐ข testAddCompareCompareWithGuava
๐ข testSpanWithGuava
๐ข testDeleteCompareWithGuava
๐ข testFirstRange
๐ข testAddForSameKey
๐ข testDeleteWithAtMost
๐ข testRangeContaining
```
### ๐ขย org.apache.pulsar.common.util.collections.ConcurrentSortedLongPairSetTest
```
๐ข concurrentInsertions
๐ข testIfRemoval
๐ข testRemoval
๐ข testRemove
๐ข testItems
๐ข testEqualsObjects
๐ข simpleInsertions
๐ข testIteration
๐ข testToString
```
### ๐ขย org.apache.pulsar.common.util.collections.FieldParserTest
```
๐ข testUpdateObject
๐ข testConversion
```
### ๐ขย org.apache.pulsar.common.util.collections.GrowableArrayBlockingQueueTest
```
๐ข removeTest
๐ข growArray
๐ข pollTimeout
๐ข simple
๐ข pollTimeout2
๐ข blockingTake
```
### ๐ขย org.apache.pulsar.common.util.collections.GrowablePriorityLongPairQueueTest
```
๐ข testItems
๐ข testRemove
๐ข testExpandQueue
๐ข testInsertAndRemove
๐ข testEqualsObjects
๐ข testExpandRemoval
๐ข testIteration
๐ข simpleInsertions
๐ข concurrentInsertions
๐ข testConstructor
๐ข testSetWithDuplicateInsert
๐ข testExpandWithDeletes
๐ข concurrentInsertionsAndReads
๐ข testRemoval
๐ข testIfRemoval
```
### ๐ขย org.apache.pulsar.common.util.collections.TripleLongPriorityQueueTest
```
๐ข testQueue
๐ข testCheckForEmpty
๐ข testCompareWithSamePrefix
```
### ๐ขย org.apache.pulsar.common.util.FieldParserTest
```
๐ข testMap
```
### ๐ขย org.apache.pulsar.common.util.FileModifiedTimeUpdaterTest
```
๐ข testFileNotModified
๐ข testFileModified
๐ข testFileModified
๐ข testFileNotModified
๐ข testFileModified
๐ข testFileNotModified
```
### ๐ขย org.apache.pulsar.common.util.netty.ChannelFuturesTest
```
๐ข toCompletableFuture_shouldCompleteExceptionally_channelFutureCompletedAfter
๐ข toCompletableFuture_shouldCompleteSuccessfully_channelFutureCompletedAfter
๐ข toCompletableFuture_shouldCompleteSuccessfully_channelFutureCompletedBefore
๐ข toCompletableFuture_shouldCompleteExceptionally_channelFutureCompletedBefore
๐ข toCompletableFuture_shouldRequireNonNullArgument
```
### ๐ขย org.apache.pulsar.common.util.RateLimiterTest
```
๐ข testMultipleTryAcquire
๐ข testRateLimiterWithPermitUpdater
๐ข testTryAcquire
๐ข testTryAcquireNoPermits
๐ข testClose
๐ข testResetRate
๐ข testMultipleAcquire
๐ข testAcquire
๐ข testInvalidRenewTime
๐ข testRateLimiterWithFunction
๐ข testAcquireBlock
```
### ๐ขย org.apache.pulsar.common.util.ReflectionsTest
```
๐ข testCreateInstanceNoNoArgConstructor
๐ข testCreateInstanceConstructorThrowsException
๐ข testCreateInstanceAbstractClass
๐ข testCreateTypedInstanceUnassignableClass
๐ข testCreateInstanceClassNotFound
๐ข testCreateTypedInstanceConstructorThrowsException
๐ข testClassExists
๐ข testCreateTypedInstanceAbstractClass
๐ข testCreateTypedInstanceClassNotFound
๐ข testCreateTypedInstanceNoNoArgConstructor
๐ข testLoadClass
๐ข testClassInJarImplementsIface
```
### ๐ขย org.apache.pulsar.common.util.RelativeTimeUtilTest
```
๐ข testParseRelativeTime
```
### ๐ขย org.apache.pulsar.discovery.service.web.DiscoveryServiceWebTest
```
๐ข testRedirectUrlWithServerStarted
```
### ๐ขย org.apache.pulsar.functions.worker.PulsarFunctionE2ESecurityTest
```
๐ข testAuthorizationWithAnonymousUser
๐ข testAuthorization
```
### ๐ขย org.apache.pulsar.functions.worker.PulsarFunctionPublishTest
```
๐ข testPulsarFunctionState
๐ข testMultipleAddress
๐ข testPulsarFunctionBKCleanup
```
### ๐ขย org.apache.pulsar.functions.worker.PulsarFunctionTlsTest
```
๐ข testFunctionsCreation
```
### ๐ขย org.apache.pulsar.io.PulsarFunctionTlsTest
```
๐ข testAuthorization
```
### ๐ขย org.apache.pulsar.proxy.server.AdminProxyHandlerTest
```
๐ข replayableProxyContentProviderTest
```
### ๐ขย org.apache.pulsar.proxy.server.AuthedAdminProxyHandlerTest
```
๐ข testAuthenticatedProxyAsNonAdmin
```
### ๐ขย org.apache.pulsar.proxy.server.FunctionWorkerRoutingTest
```
๐ข testFunctionWorkerRedirect
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyAdditionalServletTest
```
๐ข test
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyAuthenticatedProducerConsumerTest
```
๐ข testTlsSyncProducerAndConsumer
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyAuthenticationTest
```
๐ข testAuthentication
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyConnectionThrottlingTest
```
๐ข testInboundConnection
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyEnableHAProxyProtocolTest
```
๐ข testSimpleProduceAndConsume
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyForwardAuthDataTest
```
๐ข testForwardAuthData
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyIsAHttpProxyTest
```
๐ข testProxyToEndsInSlash
๐ข testStreaming
๐ข testLongPath
๐ข testLongPathInProxyTo
๐ข testPathEndsInSlash
๐ข testPathNotSpecified
๐ข testTryingToUseExistingPath
๐ข testMultipleRedirect
๐ข testSingleRedirect
๐ข testRedirectNotSpecified
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyKeyStoreTlsTestWithAuth
```
๐ข testProducerFailed
๐ข testPartitions
๐ข testProducer
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyKeyStoreTlsTestWithoutAuth
```
๐ข testPartitions
๐ข testProducerFailed
๐ข testProducer
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyLookupThrottlingTest
```
๐ข testLookup
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyParserTest
```
๐ข testRegexSubscription
๐ข testProducerConsumer
๐ข testProducer
๐ข testPartitions
๐ข testProtocolVersionAdvertisement
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyRolesEnforcementTest
```
๐ข testIncorrectRoles
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyStatsTest
```
๐ข testChangeLogLevel
๐ข testConnectionsStats
๐ข testTopicStats
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyTest
```
๐ข testPartitions
๐ข testRegexSubscription
๐ข testProtocolVersionAdvertisement
๐ข testGetSchema
๐ข testProducer
๐ข testProducerConsumer
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyTlsTest
```
๐ข testProducer
๐ข testPartitions
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyTlsTestWithAuth
```
๐ข testServiceStartup
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyWithAuthorizationNegTest
```
๐ข testProxyAuthorization
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyWithAuthorizationTest
```
๐ข tlsCiphersAndProtocols
๐ข testTlsHostVerificationProxyToClient
๐ข tlsCiphersAndProtocols
๐ข testProxyAuthorization
๐ข tlsCiphersAndProtocols
๐ข testTlsHostVerificationProxyToBroker
๐ข tlsCiphersAndProtocols
๐ข tlsCiphersAndProtocols
๐ข tlsCiphersAndProtocols
๐ข testTlsHostVerificationProxyToBroker
๐ข tlsCiphersAndProtocols
๐ข testTlsHostVerificationProxyToClient
๐ข tlsCiphersAndProtocols
```
### ๐ขย org.apache.pulsar.proxy.server.ProxyWithoutServiceDiscoveryTest
```
๐ข testDiscoveryService
```
### ๐ขย org.apache.pulsar.proxy.server.SuperUserAuthedAdminProxyHandlerTest
```
๐ข testAuthWithRandoCert
๐ข testAuthenticatedProxyAsAdmin
๐ข testAuthenticatedProxyAsNonAdmin
```
### ๐ขย org.apache.pulsar.proxy.server.UnauthedAdminProxyHandlerTest
```
๐ข testUnauthenticatedProxy
๐ข testVipStatus
```
### ๐ขย org.apache.pulsar.PulsarBrokerStarterTest
```
๐ข testMainRunBookieNoConfig
๐ข testLoadConfigWithException
๐ข testMainWithNoArgument
๐ข testLoadBalancerConfig
๐ข testGlobalZooKeeperConfig
๐ข testMainRunBookieRecoveryNoConfig
๐ข testLoadConfig
๐ข testMainEnableRunBookieThroughBrokerConfig
๐ข testMainRunBookieAndAutoRecoveryNoConfig
```
### ๐ขย org.apache.pulsar.schema.compatibility.SchemaCompatibilityCheckTest
```
๐ข testConsumerCompatibilityCheckCanReadLastTest
๐ข testConsumerWithNotCompatibilitySchema
๐ข testProducerSendWithOldSchemaAndConsumerCanRead
๐ข testConsumerCompatibilityCheckCanReadLastTest
๐ข testProducerSendWithOldSchemaAndConsumerCanRead
๐ข testSchemaComparison
๐ข testConsumerCompatibilityCheckCanReadLastTest
๐ข testConsumerCompatibilityReadAllCheckTest
๐ข testConsumerWithNotCompatibilitySchema
๐ข testIsAutoUpdateSchema
๐ข testProducerSendWithOldSchemaAndConsumerCanRead
๐ข testConsumerCompatibilityReadAllCheckTest
๐ข testIsAutoUpdateSchema
๐ข testProducerSendWithOldSchemaAndConsumerCanRead
๐ข testConsumerWithNotCompatibilitySchema
๐ข testIsAutoUpdateSchema
๐ข testProducerSendWithOldSchemaAndConsumerCanRead
๐ข testConsumerWithNotCompatibilitySchema
๐ข testProducerSendWithOldSchemaAndConsumerCanRead
๐ข testIsAutoUpdateSchema
๐ข testIsAutoUpdateSchema
๐ข testConsumerCompatibilityCheckCanReadLastTest
๐ข testIsAutoUpdateSchema
```
### ๐ขย org.apache.pulsar.schema.PartitionedTopicSchemaTest
```
๐ข test
```
### ๐ขย org.apache.pulsar.schema.SchemaTest
```
๐ข testIsUsingAvroSchemaParser
๐ข testBytesSchemaDeserialize
๐ข testMultiTopicSetSchemaProvider
```
### ๐ขย org.apache.pulsar.stats.client.PulsarBrokerStatsClientTest
```
๐ข testServiceException
๐ข testTopicInternalStats
```
### ๐ขย org.apache.pulsar.tests.EnumValuesDataProviderTest
```
๐ข shouldFailIfEnumParameterIsMissing
๐ข testEnumValuesProvider
๐ข testEnumValuesProvider
๐ข shouldDetermineEnumValuesFromMethod
๐ข shouldContainAllEnumValues
๐ข testEnumValuesProvider
```
### ๐ขย org.apache.pulsar.tests.TestRetrySupportBeforeMethodRetryTest
```
๐ข shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod
โช shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod
โช shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod
โช shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod
โช shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod
```
### ๐ขย org.apache.pulsar.tests.TestRetrySupportRetryTest
```
โช shouldCallSetupBeforeRetrying
๐ข shouldCallSetupBeforeRetrying
โช shouldCallSetupBeforeRetrying
โช shouldCallSetupBeforeRetrying
โช shouldCallSetupBeforeRetrying
```
### ๐ขย org.apache.pulsar.tests.TestRetrySupportSuccessTest
```
๐ข shouldCallSetupOnce1
๐ข shouldCallSetupOnce3
๐ข shouldCallSetupOnce2
```
### ๐ขย org.apache.pulsar.tests.ThreadDumpUtilTest
```
๐ข testHelp
๐ข testThreadDump
```
### ๐ขย org.apache.pulsar.utils.SimpleTextOutputStreamTest
```
๐ข testBooleanFormat
๐ข testDoubleFormat
๐ข testLongFormat
๐ข testString
```
### ๐ขย org.apache.pulsar.utils.StatsOutputStreamTest
```
๐ข testLists
๐ข testNamedObjects
๐ข testNestedObjects
๐ข testNamedLists
๐ข testPairs
๐ข testObjects
```
### ๐ขย org.apache.pulsar.websocket.proxy.ProxyAuthenticationTest
```
๐ข unauthenticatedSocketTest
๐ข authenticatedSocketTest
๐ข statsTest
๐ข anonymousSocketTest
```
### ๐ขย org.apache.pulsar.websocket.proxy.ProxyAuthorizationTest
```
๐ข test
```
### ๐ขย org.apache.pulsar.websocket.proxy.ProxyConfigurationTest
```
๐ข configTest
๐ข configTest
```
### ๐ขย org.apache.pulsar.websocket.proxy.ProxyPublishConsumeTlsTest
```
๐ข socketTest
```
### ๐ขย org.apache.pulsar.websocket.proxy.ProxyPublishConsumeWithoutZKTest
```
๐ข socketTest
```
### ๐ขย org.apache.pulsar.websocket.proxy.v1.V1_ProxyAuthenticationTest
```
๐ข anonymousSocketTest
๐ข authenticatedSocketTest
๐ข statsTest
๐ข unauthenticatedSocketTest
```