
|Report|Passed|Failed|Skipped|Time|
|:---|---:|---:|---:|---:|
|fixtures/external/java/pulsar-test-report.xml|793 ✅|1 ❌|14 ⚪|2127s|
## ❌ 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
```