![Tests failed](https://img.shields.io/badge/tests-793%20passed%2C%201%20failed%2C%2014%20skipped-critical) ## ❌ 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 ```