
## ❌ 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
```