You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gi...@apache.org on 2024/12/19 16:38:24 UTC
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 12414608496
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch test-catalog
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/test-catalog by this push:
new 7f0d1c81601 Update test catalog data for GHA workflow run 12414608496
7f0d1c81601 is described below
commit 7f0d1c81601fe48964f91b2da725fd83c9c9cc48
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Thu Dec 19 16:38:16 2024 +0000
Update test catalog data for GHA workflow run 12414608496
Commit: https://github.com/apache/kafka/commit/22d1ba8265d44738ff81a5031d523a009237aa46
GitHub Run: https://github.com/apache/kafka/actions/runs/12414608496
---
test-catalog/core/tests.yaml | 4030 ------------------------------------------
1 file changed, 4030 deletions(-)
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index 6cf2a177f9a..5975f358d9c 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -1,4057 +1,27 @@
-integration.kafka.api.PlaintextConsumerCallbackTest:
-- testConsumerRebalanceListenerAssignOnPartitionsAssigned
-- testConsumerRebalanceListenerAssignOnPartitionsRevoked
-- testConsumerRebalanceListenerAssignmentOnPartitionsAssigned
-- testConsumerRebalanceListenerAssignmentOnPartitionsRevoked
-- testConsumerRebalanceListenerBeginningOffsetsOnPartitionsAssigned
-- testConsumerRebalanceListenerBeginningOffsetsOnPartitionsRevoked
-- testGetPositionOfNewlyAssignedPartitionOnPartitionsAssignedCallback
-- testSeekPositionAndPauseNewlyAssignedPartitionOnPartitionsAssignedCallback
-integration.kafka.server.DelayedFutureTest:
-- testDelayedFuture
-kafka.KafkaConfigTest:
-- testBrokerRoleNodeIdValidation
-- testCombinedRoleNodeIdValidation
-- testConnectionsMaxReauthMsDefault
-- testConnectionsMaxReauthMsExplicit
-- testControllerRoleNodeIdValidation
-- testGetKafkaConfigFromArgs
-- testGetKafkaConfigFromArgsNonArgsAtTheBegging
-- testGetKafkaConfigFromArgsNonArgsAtTheEnd
-- testGetKafkaConfigFromArgsNonArgsOnly
-- testIsKRaftCombinedMode
-- testKafkaSslPasswords
-- testKafkaSslPasswordsWithSymbols
-- testMustContainQuorumVotersIfUsingProcessRoles
-kafka.admin.AddPartitionsTest:
-- testIncrementPartitions
-- testManualAssignmentOfReplicas
-- testMissingPartitionsInCreatePartitions
-- testMissingPartitionsInCreateTopics
-- testReplicaPlacementAllServers
-- testReplicaPlacementPartialServers
-- testWrongReplicaCount
-kafka.admin.AdminFenceProducersTest:
-- testFenceAfterProducerCommit
-- testFenceBeforeProducerCommit
-- testFenceProducerTimeoutMs
-kafka.admin.AdminRackAwareTest:
-- testAssignReplicasToBrokersWithInvalidParameters
-- testAssignmentWith2ReplicasRackAware
-- testAssignmentWith2ReplicasRackAwareWith6Partitions
-- testAssignmentWith2ReplicasRackAwareWith6PartitionsAnd3Brokers
-- testAssignmentWithRackAware
-- testAssignmentWithRackAwareWithRandomStartIndex
-- testAssignmentWithRackAwareWithUnevenRacks
-- testAssignmentWithRackAwareWithUnevenReplicas
-- testGetRackAlternatedBrokerListAndAssignReplicasToBrokers
-- testLargeNumberPartitionsAssignment
-- testLessReplicasThanRacks
-- testMoreReplicasThanRacks
-- testRackAwareExpansion
-- testReplicaAssignment
-- testSingleRack
-- testSkipBrokerWithReplicaAlreadyAssigned
-kafka.admin.ClientTelemetryTest:
-- testClientInstanceId
-- testIntervalMsParser
-- testMetrics
kafka.admin.ConfigCommandIntegrationTest:
-- testAlterReadOnlyConfigInKRaftThenShouldFail
-- testClientMetricsConfigUpdate
-- testDynamicBrokerConfigUpdateUsingKraft
-- testExitWithNonZeroStatusOnUpdatingUnallowedConfig
-- testGroupConfigUpdateUsingKraft
-- testNullStatusOnKraftCommandAlterClientMetrics
-- testNullStatusOnKraftCommandAlterGroup
-- testNullStatusOnKraftCommandAlterUserQuota
- testUnsupportedVersionException
- testUpdateBrokerConfigNotAffectedByInvalidConfig
-- testUpdateClusterWideConfigInKRaftThenShouldSuccessful
- testUpdateInvalidBrokerConfigs
- testUpdateInvalidTopicConfigs
-- testUpdatePerBrokerConfigInKRaftThenShouldFail
-- testUpdatePerBrokerConfigWithListenerNameInKRaftThenShouldSuccessful
-kafka.admin.ConfigCommandTest:
-- shouldAddBrokerDynamicConfig
-- shouldAddBrokerLoggerConfig
-- shouldAddClientConfig
-- shouldAddDefaultBrokerDynamicConfig
-- shouldAlterClientMetricsConfig
-- shouldAlterGroupConfig
-- shouldAlterTopicConfig
-- shouldDescribeClientMetricsConfigWithoutEntityName
-- shouldDescribeConfigBrokerWithoutEntityName
-- shouldDescribeConfigSynonyms
-- shouldDescribeGroupConfigWithoutEntityName
-- shouldExitWithNonZeroStatusAlterUserQuotaWithoutEntityName
-- shouldExitWithNonZeroStatusIfBothBootstrapServerAndBootstrapControllerGiven
-- shouldExitWithNonZeroStatusOnArgError
-- shouldExitWithNonZeroStatusOnBrokerCommandError
-- shouldFailIfAddAndAddFile
-- shouldFailIfBrokerEntityTypeIsNotAnInteger
-- shouldFailIfInvalidHost
-- shouldFailIfMixedEntityTypeFlags
-- shouldFailIfShortBrokerEntityTypeIsNotAnInteger
-- shouldFailIfUnrecognisedEntityType
-- shouldFailIfUnresolvableHost
-- shouldNotAlterClientMetricsConfigWithoutEntityName
-- shouldNotAlterGroupConfigWithoutEntityName
-- shouldNotAlterNonQuotaIpConfigsUsingBootstrapServer
-- shouldNotAlterNonQuotaNonScramUserOrClientConfigUsingBootstrapServer
-- shouldNotAlterScramClientConfigUsingBootstrapServer
-- shouldNotAlterUserScramCredentialAndClientQuotaConfigsSimultaneouslyUsingBootstrapServer
-- shouldNotCreateUserScramCredentialConfigWithUnderMinimumIterationsUsingBootstrapServer
-- shouldNotDescribeUserScramCredentialsWithEntityDefaultUsingBootstrapServer
-- shouldNotUpdateBrokerConfigIfMalformedBracketConfig
-- shouldNotUpdateBrokerConfigIfMalformedConfig
-- shouldNotUpdateBrokerConfigIfMalformedEntityName
-- shouldNotUpdateConfigIfNonExistingConfigIsDeleted
-- shouldParseArgumentsForBrokerLoggersEntityTypeWithBrokerBootstrap
-- shouldParseArgumentsForBrokerLoggersEntityTypeWithControllerBootstrap
-- shouldParseArgumentsForBrokersEntityTypeWithBrokerBootstrap
-- shouldParseArgumentsForBrokersEntityTypeWithControllerBootstrap
-- shouldParseArgumentsForClientsEntityTypeWithBrokerBootstrap
-- shouldParseArgumentsForClientsEntityTypeWithControllerBootstrap
-- shouldParseArgumentsForGroupEntityTypeWithBrokerBootstrap
-- shouldParseArgumentsForGroupEntityTypeWithControllerBootstrap
-- shouldParseArgumentsForIpEntityTypeWithBrokerBootstrap
-- shouldParseArgumentsForIpEntityTypeWithControllerBootstrap
-- shouldParseArgumentsForTopicsEntityTypeWithBrokerBootstrap
-- shouldParseArgumentsForTopicsEntityTypeWithControllerBootstrap
-- shouldParseArgumentsForUsersEntityTypeWithBrokerBootstrap
-- shouldParseArgumentsForUsersEntityTypeWithControllerBootstrap
-- shouldRaiseInvalidConfigurationExceptionWhenAddingInvalidBrokerLoggerConfig
-- testAlterIpConfig
-- testDescribeAllBrokerConfig
-- testDescribeAllTopicConfig
-- testDescribeIpConfigs
-- testEntityDefaultForType
-- testEntityDefaultOptionWithAlterBrokerLoggerIsNotAllowed
-- testEntityDefaultOptionWithDescribeBrokerLoggerIsNotAllowed
-- testNoSpecifiedEntityOptionWithDescribeBrokersInBootstrapServerIsAllowed
-- testOptionEntityTypeNames
-- testParseConfigsToBeAddedForAddConfigFile
-kafka.admin.DeleteTopicTest:
-- testAddPartitionDuringDeleteTopic
-- testDeleteNonExistingTopic
-- testDeleteTopicAlreadyMarkedAsDeleted
-- testDeleteTopicDuringAddPartition
-- testDeleteTopicWithAllAliveReplicas
-- testDeleteTopicWithCleaner
-- testDisableDeleteTopic
-- testIncreasePartitionCountDuringDeleteTopic
-- testPartitionReassignmentDuringDeleteTopic
-- testRecreateTopicAfterDeletion
-- testResumeDeleteTopicWithRecoveredFollower
-kafka.admin.ListOffsetsIntegrationTest:
-- testListMaxTimestampWithEmptyLog
-- testThreeCompressedRecordsInOneBatch
-- testThreeCompressedRecordsInSeparateBatch
-- testThreeNonCompressedRecordsInOneBatch
-- testThreeNonCompressedRecordsInSeparateBatch
-- testThreeRecordsInOneBatchHavingDifferentCompressionTypeWithServer
-- testThreeRecordsInSeparateBatchHavingDifferentCompressionTypeWithServer
-kafka.admin.RemoteTopicCrudTest:
-- testClusterWideDisablementOfTieredStorageWithEnabledTieredTopic
-- testClusterWithoutTieredStorageStartsSuccessfullyIfTopicWithTieringDisabled
-- testCreateCompactedRemoteStorage
-- testCreateRemoteTopicWithCopyDisabledAndDeleteOnDisable
-- testCreateRemoteTopicWithInheritedLocalRetentionSize
-- testCreateRemoteTopicWithInheritedLocalRetentionTime
-- testCreateRemoteTopicWithInvalidRetentionSize
-- testCreateRemoteTopicWithInvalidRetentionTime
-- testCreateRemoteTopicWithValidRetentionSize
-- testCreateRemoteTopicWithValidRetentionTime
-- testCreateTopicRetentionBytesValidationWithRemoteCopyDisabled
-- testCreateTopicRetentionMsValidationWithRemoteCopyDisabled
-- testEnableRemoteLogOnExistingTopicTest
-- testEnableRemoteLogWhenSystemRemoteStorageIsDisabled
-- testTopicDeletion
-- testUpdateTopicConfigWithDisablingRemoteStorage
-- testUpdateTopicConfigWithInheritedLocalRetentionSize
-- testUpdateTopicConfigWithInheritedLocalRetentionTime
-- testUpdateTopicConfigWithValidRetentionSizeTest
-- testUpdateTopicConfigWithValidRetentionTimeTest
-kafka.admin.UserScramCredentialsCommandTest:
-- testAlterWithEmptyPassword
-- testDescribeUnknownUser
-- testUserScramCredentialsRequests
-kafka.api.AdminClientRebootstrapTest:
-- testRebootstrap
-kafka.api.AdminClientWithPoliciesIntegrationTest:
-- testInvalidAlterConfigs
-- testInvalidAlterConfigsDueToPolicy
-- testValidAlterConfigs
-kafka.api.AuthorizerIntegrationTest:
-- shouldInitTransactionsWhenAclSet
-- shouldNotIncludeUnauthorizedTopicsInDescribeTransactionsResponse
-- shouldSendSuccessfullyWhenIdempotentAndHasCorrectACL
-- shouldSuccessfullyAbortTransactionAfterTopicAuthorizationException
-- shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessDuringSend
-- shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnEndTransaction
-- shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnSendOffsetsToTxn
-- testAuthorizationFetchV12WithTopicNotExisting
-- testAuthorizationWithTopicExisting
-- testAuthorizationWithTopicNotExisting
-- testAuthorizeByResourceTypeDenyTakesPrecedence
-- testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow
-- testAuthorizeByResourceTypeMultipleAddAndRemove
-- testAuthorizeByResourceTypePrefixedResourceDenyDominate
-- testAuthorizeByResourceTypeWildcardResourceDenyDominate
-- testClusterId
-- testCommitWithNoAccess
-- testCommitWithNoGroupAccess
-- testCommitWithNoTopicAccess
-- testCommitWithTopicAndGroupRead
-- testCommitWithTopicDescribe
-- testCommitWithTopicWrite
-- testConsumeUsingAssignWithNoAccess
-- testConsumeWithTopicAndGroupRead
-- testConsumeWithTopicDescribe
-- testConsumeWithTopicWrite
-- testConsumeWithoutTopicDescribeAccess
-- testConsumerGroupDescribeWithDescribeAcl
-- testConsumerGroupDescribeWithOperationAll
-- testConsumerGroupDescribeWithoutDescribeAcl
-- testConsumerGroupHeartbeatWithOperationAll
-- testConsumerGroupHeartbeatWithReadAcl
-- testConsumerGroupHeartbeatWithoutReadAcl
-- testCreateAndCloseConsumerWithNoAccess
-- testCreatePartitionsWithWildCardAuth
-- testCreatePermissionMetadataRequestAutoCreate
-- testCreatePermissionOnClusterToReadFromNonExistentTopic
-- testCreatePermissionOnClusterToWriteToNonExistentTopic
-- testCreatePermissionOnTopicToReadFromNonExistentTopic
-- testCreatePermissionOnTopicToWriteToNonExistentTopic
-- testCreateTopicAuthorizationWithClusterCreate
-- testDeleteGroupApiWithDeleteGroupAcl
-- testDeleteGroupApiWithNoDeleteGroupAcl
-- testDeleteGroupApiWithNoDeleteGroupAcl2
-- testDeleteGroupOffsetsWithAcl
-- testDeleteGroupOffsetsWithDeleteAclWithoutTopicAcl
-- testDeleteGroupOffsetsWithNoAcl
-- testDeleteGroupOffsetsWithoutDeleteAcl
-- testDeleteRecordsWithWildCardAuth
-- testDeleteTopicsWithWildCardAuth
-- testDescribeClusterClusterAuthorizedOperationsWithDescribeAndAlterCluster
-- testDescribeClusterClusterAuthorizedOperationsWithoutDescribeCluster
-- testDescribeGroupApiWithGroupDescribe
-- testDescribeGroupApiWithNoGroupAcl
-- testDescribeGroupConfigsWithDescribeAcl
-- testDescribeGroupConfigsWithOperationAll
-- testDescribeGroupConfigsWithoutDescribeAcl
-- testDescribeTopicAclWithOperationAll
-- testDescribeTopicConfigsAclWithOperationAll
-- testFetchFollowerRequest
-- testHostAddressBasedAcls
-- testIdempotentProducerNoIdempotentWriteAclInInitProducerId
-- testIdempotentProducerNoIdempotentWriteAclInProduce
-- testIncrementalAlterConfigsRequestRequiresClusterPermissionForBrokerLogger
-- testIncrementalAlterGroupConfigsWithAlterAcl
-- testIncrementalAlterGroupConfigsWithOperationAll
-- testIncrementalAlterGroupConfigsWithoutAlterAcl
-- testListGroupApiWithAndWithoutListGroupAcls
-- testListOffsetsWithNoTopicAccess
-- testListOffsetsWithTopicDescribe
-- testListTransactionsAuthorization
-- testMetadataClusterAuthorizedOperationsWithDescribeAndAlterCluster
-- testMetadataClusterAuthorizedOperationsWithoutDescribeCluster
-- testMetadataWithNoTopicAccess
-- testMetadataWithTopicDescribe
-- testOffsetFetchAllTopicPartitionsAuthorization
-- testOffsetFetchMultipleGroupsAuthorization
-- testOffsetFetchTopicDescribe
-- testOffsetFetchWithNoAccess
-- testOffsetFetchWithNoGroupAccess
-- testOffsetFetchWithNoTopicAccess
-- testOffsetFetchWithTopicAndGroupRead
-- testOffsetsForLeaderEpochClusterPermission
-- testPatternSubscriptionMatchingInternalTopic
-- testPatternSubscriptionMatchingInternalTopicWithDescribeOnlyPermission
-- testPatternSubscriptionNotMatchingInternalTopic
-- testPatternSubscriptionWithNoTopicAccess
-- testPatternSubscriptionWithTopicAndGroupRead
-- testPatternSubscriptionWithTopicDescribeOnlyAndGroupRead
-- testPrefixAcls
-- testProduceWithNoTopicAccess
-- testProduceWithTopicDescribe
-- testProduceWithTopicRead
-- testProduceWithTopicWrite
-- testRetryProducerInitializationAfterPermissionFix
-- testSendOffsetsWithNoConsumerGroupDescribeAccess
-- testSendOffsetsWithNoConsumerGroupWriteAccess
-- testSimpleConsumeWithExplicitSeekAndNoGroupAccess
-- testSimpleConsumeWithOffsetLookupAndNoGroupAccess
-- testTopicIdAuthorization
-- testTransactionalProducerInitTransactionsNoDescribeTransactionalIdAcl
-- testTransactionalProducerInitTransactionsNoWriteTransactionalIdAcl
-- testTransactionalProducerTopicAuthorizationExceptionInCommit
-- testTransactionalProducerTopicAuthorizationExceptionInSendCallback
-- testUnauthorizedCreatePartitions
-- testUnauthorizedDeleteRecordsWithDescribe
-- testUnauthorizedDeleteRecordsWithoutDescribe
-- testUnauthorizedDeleteTopicsWithDescribe
-- testUnauthorizedDeleteTopicsWithoutDescribe
-kafka.api.ClientIdQuotaTest:
-- testProducerConsumerOverrideLowerQuota
-- testProducerConsumerOverrideUnthrottled
-- testQuotaOverrideDelete
-- testThrottledProducerConsumer
-- testThrottledRequest
-kafka.api.ConsumerBounceTest:
-- testClose
-- testCloseDuringRebalance
-- testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize
-- testConsumptionWithBrokerFailures
-- testSeekAndCommitWithBrokerFailures
-- testSubscribeWhenTopicUnavailable
-kafka.api.ConsumerTopicCreationTest:
-- testAutoTopicCreation
-kafka.api.ConsumerWithLegacyMessageFormatIntegrationTest:
-- testEarliestOrLatestOffsets
-- testOffsetsForTimes
-kafka.api.DelegationTokenEndToEndAuthorizationTest:
-- testCreateUserWithDelegationToken
-- testNoConsumeWithDescribeAclViaAssign
-- testNoConsumeWithDescribeAclViaSubscribe
-- testNoConsumeWithoutDescribeAclViaAssign
-- testNoConsumeWithoutDescribeAclViaSubscribe
-- testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
-- testNoGroupAcl
-- testNoProduceWithDescribeAcl
-- testProduceConsumeTopicAutoCreateTopicCreateAcl
-- testProduceConsumeViaAssign
-- testProduceConsumeViaSubscribe
-- testProduceConsumeWithPrefixedAcls
-- testProduceConsumeWithWildcardAcls
-kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest:
-- testCreateTokenForOtherUserFails
-- testCreateUserWithDelegationToken
-- testDescribeTokenForOtherUserFails
-- testDescribeTokenForOtherUserPasses
-- testNoConsumeWithDescribeAclViaAssign
-- testNoConsumeWithDescribeAclViaSubscribe
-- testNoConsumeWithoutDescribeAclViaAssign
-- testNoConsumeWithoutDescribeAclViaSubscribe
-- testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
-- testNoGroupAcl
-- testNoProduceWithDescribeAcl
-- testProduceConsumeTopicAutoCreateTopicCreateAcl
-- testProduceConsumeViaAssign
-- testProduceConsumeViaSubscribe
-- testProduceConsumeWithPrefixedAcls
-- testProduceConsumeWithWildcardAcls
-kafka.api.EndToEndClusterIdTest:
-- testEndToEnd
-kafka.api.GroupAuthorizerIntegrationTest:
-- testAuthorizedProduceAndConsume
-- testConsumeCloseWithoutGroupPermission
-- testConsumeUnsubscribeWithoutGroupPermission
-- testUnauthorizedProduceAndConsume
-kafka.api.GroupCoordinatorIntegrationTest:
-- testCoordinatorFailoverAfterCompactingPartitionWithConsumerGroupDeleted
-- testCoordinatorFailoverAfterCompactingPartitionWithConsumerGroupMemberJoiningAndLeaving
-- testCoordinatorFailoverAfterCompactingPartitionWithUpgradedConsumerGroup
-- testCoordinatorFailoverCompactingPartitionWithManualOffsetCommitsAndConsumerGroupMemberUnsubscribingAndResubscribing
-- testGroupCoordinatorPropagatesOffsetsTopicCompressionCodec
-kafka.api.GroupEndToEndAuthorizationTest:
-- testAuthentications
-- testNoConsumeWithDescribeAclViaAssign
-- testNoConsumeWithDescribeAclViaSubscribe
-- testNoConsumeWithoutDescribeAclViaAssign
-- testNoConsumeWithoutDescribeAclViaSubscribe
-- testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
-- testNoGroupAcl
-- testNoProduceWithDescribeAcl
-- testProduceConsumeTopicAutoCreateTopicCreateAcl
-- testProduceConsumeViaAssign
-- testProduceConsumeViaSubscribe
-- testProduceConsumeWithPrefixedAcls
-- testProduceConsumeWithWildcardAcls
-- testTwoConsumersWithDifferentSaslCredentials
-kafka.api.LogAppendTimeTest:
-- testProduceConsume
-kafka.api.MetricsTest:
-- testMetrics
-kafka.api.PlaintextAdminIntegrationTest:
-- testAbortTransaction
-- testAbortTransactionTimeout
-- testAclOperations
-- testAdminClientHandlingBadIPWithoutTimeout
-- testAlterLogDirsAfterDeleteRecords
-- testAlterReplicaLogDirs
-- testAppendAlreadyExistsConfigsAndSubtractNotExistsConfigs
-- testAppendConfigToEmptyDefaultValue
-- testAppendConfigToExistentValue
-- testAuthorizedOperations
-- testCallInFlightTimeouts
-- testClose
-- testConsumeAfterDeleteRecords
-- testConsumerGroupWithMemberMigration
-- testConsumerGroups
-- testConsumerGroupsDeprecatedConsumerGroupState
-- testCreateDeleteTopics
-- testCreateExistingTopicsThrowTopicExistsException
-- testCreatePartitionWithOptionRetryOnQuotaViolation
-- testCreatePartitions
-- testCreateTopicsReturnsConfigs
-- testDelayedClose
-- testDeleteConsumerGroupOffsets
-- testDeleteRecordsAfterCorruptRecords
-- testDeleteRecordsWithException
-- testDeleteTopicsWithIds
-- testDeleteTopicsWithOptionTimeoutMs
-- testDescribeAndAlterConfigs
-- testDescribeClassicGroups
-- testDescribeCluster
-- testDescribeConfigWithOptionTimeoutMs
-- testDescribeConfigsForLog4jLogLevels
-- testDescribeConfigsForTopic
-- testDescribeConfigsNonexistent
-- testDescribeConfigsNonexistentForKraft
-- testDescribeLogDirs
-- testDescribeNonExistingTopic
-- testDescribeProducers
-- testDescribeReplicaLogDirs
-- testDescribeTopicsWithIds
-- testDescribeTopicsWithNames
-- testDescribeTopicsWithOptionPartitionSizeLimitPerResponse
-- testDescribeTopicsWithOptionTimeoutMs
-- testDescribeTransactions
-- testDescribeTransactionsTimeout
-- testDescribeUserScramCredentials
-- testDescribeUserScramCredentialsTimeout
-- testElectPreferredLeaders
-- testElectUncleanLeadersAndNoop
-- testElectUncleanLeadersForAllPartitions
-- testElectUncleanLeadersForManyPartitions
-- testElectUncleanLeadersForOnePartition
-- testElectUncleanLeadersForUnknownPartitions
-- testElectUncleanLeadersNoop
-- testElectUncleanLeadersWhenNoLiveBrokers
-- testForceClose
-- testIncludeDocumentation
-- testIncrementalAlterAndDescribeGroupConfigs
-- testIncrementalAlterConfigsDeleteAndSetBrokerConfigs
-- testIncrementalAlterConfigsDeleteBrokerConfigs
-- testIncrementalAlterConfigsForLog4jLogLevels
-- testIncrementalAlterConfigsForLog4jLogLevelsCanResetLoggerToCurrentRoot
-- testIncrementalAlterConfigsForLog4jLogLevelsCanSetToRootLogger
-- testIncrementalAlterConfigsForLog4jLogLevelsCannotResetRootLogger
-- testIncrementalAlterConfigsForLog4jLogLevelsDoesNotWorkWithInvalidConfigs
-- testInvalidAlterConfigs
-- testInvalidAlterPartitionReassignments
-- testInvalidIncrementalAlterConfigs
-- testListClientMetricsResources
-- testListClientMetricsResourcesTimeoutMs
-- testListGroups
-- testListNodes
-- testListNodesWithFencedBroker
-- testListReassignmentsDoesNotShowDeletedPartitions
-- testListReassignmentsDoesNotShowNonReassigningPartitions
-- testListTopicsWithOptionListInternal
-- testListTopicsWithOptionTimeoutMs
-- testListTransactions
-- testLogStartOffsetAfterDeleteRecords
-- testLogStartOffsetCheckpoint
-- testLongTopicNames
-- testMinimumRequestTimeouts
-- testNullConfigs
-- testOffsetsForTimesAfterDeleteRecords
-- testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords
-- testSeekAfterDeleteRecords
-- testShareGroups
-- testValidIncrementalAlterConfigs
-kafka.api.PlaintextConsumerAssignTest:
-- testAssignAndCommitAsyncNotCommitted
-- testAssignAndCommitSyncAllConsumed
-- testAssignAndCommitSyncNotCommitted
-- testAssignAndConsume
-- testAssignAndConsumeFromCommittedOffsets
-- testAssignAndConsumeSkippingPosition
-- testAssignAndFetchCommittedOffsets
-- testAssignAndRetrievingCommittedOffsetsMultipleTimes
-kafka.api.PlaintextConsumerAssignorsTest:
-- testMultiConsumerDefaultAssignor
-- testMultiConsumerDefaultAssignorAndVerifyAssignment
-- testMultiConsumerRoundRobinAssignor
-- testMultiConsumerStickyAssignor
-- testRebalanceAndRejoin
-- testRemoteAssignorInvalid
-- testRemoteAssignorRange
-- testRoundRobinAssignment
-kafka.api.PlaintextConsumerCommitTest:
-- testAsyncCommit
-- testAutoCommitIntercept
-- testAutoCommitOnClose
-- testAutoCommitOnCloseAfterWakeup
-- testAutoCommitOnRebalance
-- testCommitAsyncCompletedBeforeCommitSyncReturns
-- testCommitAsyncCompletedBeforeConsumerCloses
-- testCommitMetadata
-- testCommitSpecifiedOffsets
-- testPositionAndCommit
-- testSubscribeAndCommitSync
kafka.api.PlaintextConsumerFetchTest:
-- testFetchHonoursFetchSizeIfLargeRecordNotFirst
-- testFetchHonoursMaxPartitionFetchBytesIfLargeRecordNotFirst
-- testFetchInvalidOffset
- testFetchOutOfRangeOffsetResetConfigByDuration
-- testFetchOutOfRangeOffsetResetConfigEarliest
-- testFetchOutOfRangeOffsetResetConfigLatest
-- testFetchRecordLargerThanFetchMaxBytes
-- testFetchRecordLargerThanMaxPartitionFetchBytes
-- testLowMaxFetchSizeForRequestAndPartition
-kafka.api.PlaintextConsumerPollTest:
-- testMaxPollIntervalMs
-- testMaxPollIntervalMsDelayInAssignment
-- testMaxPollIntervalMsDelayInRevocation
-- testMaxPollIntervalMsShorterThanPollTimeout
-- testMaxPollRecords
-- testMultiConsumerSessionTimeoutOnClose
-- testMultiConsumerSessionTimeoutOnStopPolling
-- testNoOffsetForPartitionExceptionOnPollZero
-- testPerPartitionLagWithMaxPollRecords
-- testPerPartitionLeadWithMaxPollRecords
-- testPollEventuallyReturnsRecordsWithZeroTimeout
kafka.api.PlaintextConsumerSubscriptionTest:
-- testExpandingTopicSubscriptions
-- testPatternSubscription
-- testPatternUnsubscription
-- testRe2JPatternExpandSubscription
- testRe2JPatternSubscription
-- testRe2JPatternSubscriptionAndTopicSubscription
- testRe2JPatternSubscriptionInvalidRegex
-- testShrinkingTopicSubscriptions
-- testSubscribeInvalidTopicCanClose
-- testSubscribeInvalidTopicCanUnsubscribe
-- testSubsequentPatternSubscription
-- testUnsubscribeTopic
-kafka.api.PlaintextConsumerTest:
-- testAutoOffsetReset
-- testCloseLeavesGroupOnInterrupt
-- testClusterResourceListener
-- testConsumeMessagesWithCreateTime
-- testConsumeMessagesWithLogAppendTime
-- testConsumingWithNullGroupId
-- testCoordinatorFailover
-- testEndOffsets
-- testFetchOffsetsForTime
-- testGroupConsumption
-- testHeaders
-- testHeadersSerializerDeserializer
-- testInterceptors
-- testInterceptorsWithWrongKeyValue
-- testListTopics
-- testNullGroupIdNotSupportedIfCommitting
-- testPartitionPauseAndResume
-- testPartitionsFor
-- testPartitionsForAutoCreate
-- testPartitionsForInvalidTopic
-- testPauseStateNotPreservedByRebalance
-- testPerPartitionLagMetricsCleanUpWithAssign
-- testPerPartitionLagMetricsCleanUpWithSubscribe
-- testPerPartitionLagMetricsWhenReadCommitted
-- testPerPartitionLeadMetricsCleanUpWithAssign
-- testPerPartitionLeadMetricsCleanUpWithSubscribe
-- testPositionRespectsTimeout
-- testPositionRespectsWakeup
-- testPositionWithErrorConnectionRespectsWakeup
-- testQuotaMetricsNotCreatedIfNoQuotasConfigured
-- testSeek
-- testSeekThrowsIllegalStateIfPartitionsNotAssigned
-- testSimpleConsumption
-- testStaticConsumerDetectsNewPartitionCreatedAfterRestart
-kafka.api.PlaintextEndToEndAuthorizationTest:
-- testListenerName
-- testNoConsumeWithDescribeAclViaAssign
-- testNoConsumeWithDescribeAclViaSubscribe
-- testNoConsumeWithoutDescribeAclViaAssign
-- testNoConsumeWithoutDescribeAclViaSubscribe
-- testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
-- testNoGroupAcl
-- testNoProduceWithDescribeAcl
-- testProduceConsumeTopicAutoCreateTopicCreateAcl
-- testProduceConsumeViaAssign
-- testProduceConsumeViaSubscribe
-- testProduceConsumeWithPrefixedAcls
-- testProduceConsumeWithWildcardAcls
-kafka.api.PlaintextProducerSendTest:
-- testAutoCreateTopic
-- testBatchSizeZero
-- testBatchSizeZeroNoPartitionNoRecordKey
-- testClose
-- testCloseWithZeroTimeoutFromCallerThread
-- testCloseWithZeroTimeoutFromSenderThread
-- testFlush
-- testNonBlockingProducer
-- testSendBeforeAndAfterPartitionExpansion
-- testSendCompressedMessageWithCreateTime
-- testSendCompressedMessageWithLogAppendTime
-- testSendNonCompressedMessageWithCreateTime
-- testSendNonCompressedMessageWithLogAppendTime
-- testSendOffset
-- testSendRecordBatchWithMaxRequestSizeAndHigher
-- testSendToPartition
-- testSendToPartitionWithFollowerShutdownShouldNotTimeout
-- testSendWithInvalidBeforeAndAfterTimestamp
-- testValidBeforeAndAfterTimestampsAtThreshold
-- testValidBeforeAndAfterTimestampsWithinThreshold
-- testWrongSerializer
-kafka.api.ProducerFailureHandlingTest:
-- testCannotSendToInternalTopic
-- testInvalidPartition
-- testNonExistentTopic
-- testNotEnoughReplicasAfterBrokerShutdown
-- testPartitionTooLargeForReplicationWithAckAll
-- testResponseTooLargeForReplicationWithAckAll
-- testSendAfterClosed
-- testTooLargeRecordWithAckOne
-- testTooLargeRecordWithAckZero
-- testWrongBrokerList
-kafka.api.ProducerIdExpirationTest:
-- testDynamicProducerIdExpirationMs
-- testProducerIdExpirationWithNoTransactions
-- testTransactionAfterTransactionIdExpiresButProducerIdRemains
-kafka.api.ProducerSendWhileDeletionTest:
-- testSendWithTopicDeletionMidWay
-kafka.api.RackAwareAutoTopicCreationTest:
-- testAutoCreateTopic
-kafka.api.SaslClientsWithInvalidCredentialsTest:
-- testConsumerWithAuthenticationFailure
-- testKafkaAdminClientWithAuthenticationFailure
-- testManualAssignmentConsumerWithAuthenticationFailure
-- testManualAssignmentConsumerWithAutoCommitDisabledWithAuthenticationFailure
-- testProducerWithAuthenticationFailure
-- testTransactionalProducerWithAuthenticationFailure
-kafka.api.SaslGssapiSslEndToEndAuthorizationTest:
-- testNoConsumeWithDescribeAclViaAssign
-- testNoConsumeWithDescribeAclViaSubscribe
-- testNoConsumeWithoutDescribeAclViaAssign
-- testNoConsumeWithoutDescribeAclViaSubscribe
-- testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
-- testNoGroupAcl
-- testNoProduceWithDescribeAcl
-- testProduceConsumeTopicAutoCreateTopicCreateAcl
-- testProduceConsumeViaAssign
-- testProduceConsumeViaSubscribe
-- testProduceConsumeWithPrefixedAcls
-- testProduceConsumeWithWildcardAcls
-- testTwoConsumersWithDifferentSaslCredentials
-kafka.api.SaslMultiMechanismConsumerTest:
-- testClusterResourceListener
-- testCoordinatorFailover
-- testMultipleBrokerMechanisms
-- testSimpleConsumption
-kafka.api.SaslOAuthBearerSslEndToEndAuthorizationTest:
-- testNoConsumeWithDescribeAclViaAssign
-- testNoConsumeWithDescribeAclViaSubscribe
-- testNoConsumeWithoutDescribeAclViaAssign
-- testNoConsumeWithoutDescribeAclViaSubscribe
-- testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
-- testNoGroupAcl
-- testNoProduceWithDescribeAcl
-- testProduceConsumeTopicAutoCreateTopicCreateAcl
-- testProduceConsumeViaAssign
-- testProduceConsumeViaSubscribe
-- testProduceConsumeWithPrefixedAcls
-- testProduceConsumeWithWildcardAcls
-- testTwoConsumersWithDifferentSaslCredentials
-kafka.api.SaslPlainPlaintextConsumerTest:
-- testClusterResourceListener
-- testCoordinatorFailover
-- testSimpleConsumption
-kafka.api.SaslPlaintextConsumerTest:
-- testClusterResourceListener
-- testCoordinatorFailover
-- testSimpleConsumption
-kafka.api.SaslScramSslEndToEndAuthorizationTest:
-- testAuthentications
-- testNoConsumeWithDescribeAclViaAssign
-- testNoConsumeWithDescribeAclViaSubscribe
-- testNoConsumeWithoutDescribeAclViaAssign
-- testNoConsumeWithoutDescribeAclViaSubscribe
-- testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
-- testNoGroupAcl
-- testNoProduceWithDescribeAcl
-- testProduceConsumeTopicAutoCreateTopicCreateAcl
-- testProduceConsumeViaAssign
-- testProduceConsumeViaSubscribe
-- testProduceConsumeWithPrefixedAcls
-- testProduceConsumeWithWildcardAcls
-- testTwoConsumersWithDifferentSaslCredentials
-kafka.api.SaslSslAdminIntegrationTest:
-- testAclAuthorizationDenied
-- testAclDelete
-- testAclDescribe
-- testAclOperations
-- testAclOperations2
-- testAclOperationsWithOptionTimeoutMs
-- testAttemptToCreateInvalidAcls
-- testAuthorizedOperations
-- testCreateDelegationTokenWithSmallerTimeout
-- testCreateDeleteTopics
-- testCreateTokenWithOverflowTimestamp
-- testCreateTopicsResponseMetadataAndConfig
-- testDeleteAclsWithOptionTimeoutMs
-- testExpireDelegationToken
-- testExpireDelegationTokenWithOptionExpireTimePeriodMs
-- testExpireTokenWithOverflowTimestamp
-- testExpiredTimeStampLargerThanMaxLifeStamp
-- testLegacyAclOpsNeverAffectOrReturnPrefixed
-kafka.api.SaslSslConsumerTest:
-- testClusterResourceListener
-- testCoordinatorFailover
-- testSimpleConsumption
-kafka.api.SslAdminIntegrationTest:
-- testAclAuthorizationDenied
-- testAclDelete
-- testAclDescribe
-- testAclOperations
-- testAclOperations2
-- testAclOperationsWithOptionTimeoutMs
-- testAclUpdatesUsingAsynchronousAuthorizer
-- testAclUpdatesUsingSynchronousAuthorizer
-- testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads
-- testAttemptToCreateInvalidAcls
-- testAuthorizedOperations
-- testCreateDelegationTokenWithSmallerTimeout
-- testCreateDeleteTopics
-- testCreateTokenWithOverflowTimestamp
-- testCreateTopicsResponseMetadataAndConfig
-- testDeleteAclsWithOptionTimeoutMs
-- testExpireDelegationToken
-- testExpireDelegationTokenWithOptionExpireTimePeriodMs
-- testExpireTokenWithOverflowTimestamp
-- testExpiredTimeStampLargerThanMaxLifeStamp
-- testLegacyAclOpsNeverAffectOrReturnPrefixed
-- testListNodesFromControllers
-- testListNodesFromControllersIncludingFencedBrokers
-- testSynchronousAuthorizerAclUpdatesBlockRequestThreads
-kafka.api.SslConsumerTest:
-- testClusterResourceListener
-- testCoordinatorFailover
-- testSimpleConsumption
-kafka.api.SslEndToEndAuthorizationTest:
-- testNoConsumeWithDescribeAclViaAssign
-- testNoConsumeWithDescribeAclViaSubscribe
-- testNoConsumeWithoutDescribeAclViaAssign
-- testNoConsumeWithoutDescribeAclViaSubscribe
-- testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
-- testNoGroupAcl
-- testNoProduceWithDescribeAcl
-- testProduceConsumeTopicAutoCreateTopicCreateAcl
-- testProduceConsumeViaAssign
-- testProduceConsumeViaSubscribe
-- testProduceConsumeWithPrefixedAcls
-- testProduceConsumeWithWildcardAcls
-kafka.api.SslProducerSendTest:
-- testClose
-- testCloseWithZeroTimeoutFromCallerThread
-- testCloseWithZeroTimeoutFromSenderThread
-- testFlush
-- testSendBeforeAndAfterPartitionExpansion
-- testSendCompressedMessageWithCreateTime
-- testSendNonCompressedMessageWithCreateTime
-- testSendOffset
-- testSendToPartition
-- testSendToPartitionWithFollowerShutdownShouldNotTimeout
-kafka.api.TransactionsBounceTest:
-- testWithGroupMetadata
-kafka.api.TransactionsExpirationTest:
-- testFatalErrorAfterInvalidProducerIdMapping
-- testTransactionAfterProducerIdExpires
-kafka.api.TransactionsTest:
-- testAbortTransactionTimeout
-- testBasicTransactions
-- testBumpTransactionalEpochWithTV2Disabled
-- testBumpTransactionalEpochWithTV2Enabled
-- testCommitTransactionTimeout
-- testConsecutivelyRunInitTransactions
-- testDelayedFetchIncludesAbortedTransaction
-- testFailureToFenceEpoch
-- testFencingOnAddPartitions
-- testFencingOnCommit
-- testFencingOnSend
-- testFencingOnSendOffsets
-- testFencingOnTransactionExpiration
-- testInitTransactionsTimeout
-- testMultipleMarkersOneLeader
-- testOffsetMetadataInSendOffsetsToTransaction
-- testReadCommittedConsumerShouldNotSeeUndecidedData
-- testSendOffsetsToTransactionTimeout
-- testSendOffsetsWithGroupMetadata
-kafka.api.TransactionsWithMaxInFlightOneTest:
-- testTransactionalProducerSingleBrokerMaxInFlightOne
-kafka.api.UserClientIdQuotaTest:
-- testProducerConsumerOverrideLowerQuota
-- testProducerConsumerOverrideUnthrottled
-- testQuotaOverrideDelete
-- testThrottledProducerConsumer
-- testThrottledRequest
-kafka.api.UserQuotaTest:
-- testProducerConsumerOverrideLowerQuota
-- testProducerConsumerOverrideUnthrottled
-- testQuotaOverrideDelete
-- testThrottledProducerConsumer
-- testThrottledRequest
-kafka.api.test.ProducerCompressionTest:
-- testCompression
-kafka.clients.consumer.ConsumerIntegrationTest:
-- testAsyncConsumerWithOldGroupCoordinator
-- testFetchPartitionsAfterFailedListenerWithGroupProtocolClassic
-- testFetchPartitionsAfterFailedListenerWithGroupProtocolConsumer
-- testFetchPartitionsWithAlwaysFailedListenerWithGroupProtocolClassic
-- testFetchPartitionsWithAlwaysFailedListenerWithGroupProtocolConsumer
-kafka.cluster.AssignmentStateTest:
-- testPartitionAssignmentStatus
-kafka.cluster.BrokerEndPointTest:
-- testFromJsonFutureVersion
-- testFromJsonV1
-- testFromJsonV2
-- testFromJsonV3
-- testFromJsonV4WithNoFeatures
-- testFromJsonV4WithNoRack
-- testFromJsonV4WithNullRack
-- testFromJsonV5
-- testHashAndEquals
-kafka.cluster.PartitionLockTest:
-- testAppendReplicaFetchWithSchedulerCheckForShrinkIsr
-- testAppendReplicaFetchWithUpdateIsr
-- testGetReplicaWithUpdateAssignmentAndIsr
-- testNoLockContentionWithoutIsrUpdate
-kafka.cluster.PartitionTest:
-- makeFollowerInvokesgetOrCreateLog_OnOnlineLogDir
-- makeFollowerInvokesgetOrCreateLog_WhenNoLogDirOffline
-- makeFollowerInvokesgetOrCreateLog_WhenTargetDirIsUnassigned
-- makeLeaderInvokesgetOrCreateLog_OnOnlineLogDir
-- makeLeaderInvokesgetOrCreateLog_WhenNoLogDirOffline
-- makeLeaderInvokesgetOrCreateLog_WhenTargetDirIsUnassigned
-- testAddAndRemoveListeners
-- testAddAndRemoveMetrics
-- testAddListenerFailsWhenPartitionIsDeleted
-- testAlterIsrInvalidVersion
-- testAlterIsrLeaderAndIsrRace
-- testAlterIsrNewLeaderElected
-- testAlterIsrUnexpectedError
-- testAlterIsrUnknownTopic
-- testAppendRecordsAsFollowerBelowLogStartOffset
-- testAppendRecordsToFollowerWithNoReplicaThrowsException
-- testAtMinIsr
-- testDoNotResetReplicaStateIfLeaderEpochIsNotBumped
-- testDoNotUpdateEpochStartOffsetIfLeaderEpochIsNotBumped
-- testFenceFollowerFetchWithStaleBrokerEpoch
-- testFetchFromUnrecognizedFollower
-- testFetchLatestOffsetIncludesLeaderEpoch
-- testFetchOffsetForTimestampEpochValidationForFollower
-- testFetchOffsetForTimestampEpochValidationForLeader
-- testFetchOffsetSnapshotEpochValidationForFollower
-- testFetchOffsetSnapshotEpochValidationForLeader
-- testFollowerDoesNotJoinISRUntilCaughtUpToOffsetWithinCurrentLeaderEpoch
-- testFollowerShouldNotHaveAnyRemoteReplicaStates
-- testGetReplica
-- testHighWatermarkAdvanceShouldNotAdvanceWhenUnderMinISR
-- testHighWatermarkIncreasesWithFencedOrShutdownFollower
-- testIgnoreFollowerPartitionStateChangeWithOlderPartitionEpoch
-- testIgnoreLeaderPartitionStateChangeWithOlderPartitionEpoch
-- testInvalidAlterPartitionRequestsAreNotRetried
-- testIsReplicaIsrEligibleWithEmptyReplicaMap
-- testIsUnderMinIsr
-- testIsrCanExpandedIfBrokerEpochsMatchWithKraftMetadataCache
-- testIsrExpansion
-- testIsrNotExpandedIfReplicaIsFencedOrShutdown
-- testIsrNotExpandedIfReplicaIsInControlledShutdown
-- testIsrNotExpandedIfUpdateFails
-- testIsrNotShrunkIfUpdateFails
-- testLastFetchedOffsetValidation
-- testLeaderEpochValidationOnFollower
-- testLeaderEpochValidationOnLeader
-- testListOffsetIsolationLevels
-- testLogConfigDirtyAsBrokerUpdated
-- testLogConfigDirtyAsTopicUpdated
-- testLogConfigNotDirty
-- testMakeFollowerWithNoLeaderIdChange
-- testMakeFollowerWithWithFollowerAppendRecords
-- testMakeLeaderUpdatesEpochCache
-- testMaybeReplaceCurrentWithFutureReplica
-- testMaybeReplaceCurrentWithFutureReplicaDifferentBaseOffsets
-- testMaybeShrinkIsr
-- testMaybeStartTransactionVerification
-- testMonotonicOffsetsAfterLeaderChange
-- testOffsetForLeaderEpochValidationForFollower
-- testOffsetForLeaderEpochValidationForLeader
-- testPartitionListenerWhenCurrentIsReplacedWithFutureLog
-- testPartitionListenerWhenLogOffsetsChanged
-- testPartitionListenerWhenPartitionFailed
-- testPartitionListenerWhenPartitionIsDeleted
-- testPartitionShouldRetryAlterPartitionRequest
-- testReplicaFetchToFollower
-- testRetryShrinkIsr
-- testShouldNotShrinkIsrIfFollowerCaughtUpToLogEnd
-- testShouldNotShrinkIsrIfPreviousFetchIsCaughtUp
-- testSingleInFlightAlterIsr
-- testTopicIdAndPartitionMetadataFileForFollower
-- testTopicIdAndPartitionMetadataFileForLeader
-- testUnderReplicatedPartitionsCorrectSemantics
-- testUpdateAssignmentAndIsr
-- testUpdateFollowerFetchState
-- testUseCheckpointToInitializeHighWatermark
-- testZkIsrManagerAsyncCallback
-- tryCompleteDelayedRequestsCatchesExceptions
-kafka.cluster.PartitionWithLegacyMessageFormatTest:
-- testMakeLeaderDoesNotUpdateEpochCacheForOldFormats
-kafka.cluster.ReplicaTest:
-- testFenceStaleUpdates
-- testInitialState
-- testIsCaughtUpWhenReplicaIsCaughtUpToLogEnd
-- testIsCaughtUpWhenReplicaIsNotCaughtUpToLogEnd
-- testResetReplicaStateWhenLeaderIsReelectedAndReplicaIsInSync
-- testResetReplicaStateWhenLeaderIsReelectedAndReplicaIsNotInSync
-- testResetReplicaStateWhenNewLeaderIsElectedAndReplicaIsInSync
-- testResetReplicaStateWhenNewLeaderIsElectedAndReplicaIsNotInSync
-- testUpdateFetchState
-kafka.coordinator.group.CoordinatorLoaderImplTest:
-- testDeserializationErrorFailsTheLoading
-- testLoadGroupAndOffsetsWithCorruptedLog
-- testLoadSummary
-- testLoading
-- testLoadingIsRejectedWhenClosed
-- testLoadingStoppedWhenClosed
-- testNonexistentPartition
-- testPartitionGoesOfflineDuringLoad
-- testUnknownRecordTypeAreIgnored
-- testUpdateLastWrittenOffsetAndUpdateLastCommittedOffsetNoRecordsRead
-- testUpdateLastWrittenOffsetOnBatchLoaded
-- testUpdateLastWrittenOffsetOnBatchLoadedWhileHighWatermarkAhead
-kafka.coordinator.group.CoordinatorPartitionWriterTest:
-- testConfig
-- testDeleteRecordsResponseContainsError
-- testDeleteRecordsSuccess
-- testMaybeStartTransactionVerification
-- testRegisterDeregisterListener
-- testWriteRecords
-- testWriteRecordsWithFailure
-kafka.coordinator.group.GroupCoordinatorAdapterTest:
-- testCommitOffsets
-- testCommitTransactionalOffsets
-- testConsumerGroupDescribe
-- testDeleteGroups
-- testDeleteOffsetsWithGroupLevelError
-- testDescribeGroup
-- testFetchAllOffsets
-- testFetchOffsets
-- testHeartbeat
-- testJoinConsumerGroup
-- testJoinGroup
-- testJoinShareGroup
-- testListGroups
-- testOnTransactionCompletedWithUnexpectedException
-- testShareGroupDescribe
-- testSyncGroup
-kafka.coordinator.group.GroupCoordinatorConcurrencyTest:
-- testConcurrentGoodPathSequence
-- testConcurrentJoinGroupEnforceGroupMaxSize
-- testConcurrentRandomSequence
-- testConcurrentTxnGoodPathSequence
-kafka.coordinator.group.GroupCoordinatorTest:
-- shouldDelayInitialRebalanceByGroupInitialRebalanceDelayOnEmptyGroup
-- shouldDelayRebalanceUptoRebalanceTimeout
-- shouldGetDifferentStaticMemberIdAfterEachRejoin
-- shouldResetRebalanceDelayWhenNewMemberJoinsGroupInInitialRebalance
-- staticMemberCommitOffsetWithInvalidMemberId
-- staticMemberFenceDuplicateRejoinedFollower
-- staticMemberFenceDuplicateRejoiningFollowerAfterMemberIdChanged
-- staticMemberFenceDuplicateSyncingFollowerAfterMemberIdChanged
-- staticMemberHeartbeatLeaderWithInvalidMemberId
-- staticMemberJoinAsFirstMember
-- staticMemberJoinWithUnknownInstanceIdAndKnownMemberId
-- staticMemberReJoinWithExplicitUnknownMemberId
-- staticMemberReJoinWithIllegalStateAsUnknownMember
-- staticMemberRejoinAsFollowerWithKnownMemberIdAndNoProtocolChange
-- staticMemberRejoinAsFollowerWithMismatchedMemberId
-- staticMemberRejoinAsFollowerWithUnknownMemberId
-- staticMemberRejoinAsLeaderWithMismatchedMemberId
-- staticMemberRejoinWithFollowerIdAndChangeOfProtocol
-- staticMemberRejoinWithKnownLeaderIdToTriggerRebalanceAndFollowerWithChangeOfProtocol
-- staticMemberRejoinWithKnownMemberId
-- staticMemberRejoinWithLeaderIdAndKnownMemberId
-- staticMemberRejoinWithLeaderIdAndUnexpectedDeadGroup
-- staticMemberRejoinWithLeaderIdAndUnexpectedEmptyGroup
-- staticMemberRejoinWithLeaderIdAndUnknownMemberId
-- staticMemberRejoinWithUnknownMemberIdAndChangeOfProtocolWhileSelectProtocolUnchanged
-- staticMemberRejoinWithUnknownMemberIdAndChangeOfProtocolWhileSelectProtocolUnchangedPersistenceFailure
-- staticMemberRejoinWithUnknownMemberIdAndChangeOfProtocolWithSelectedProtocolChanged
-- staticMemberRejoinWithUpdatedSessionAndRebalanceTimeoutsAndPersistChange
-- staticMemberRejoinWithUpdatedSessionAndRebalanceTimeoutsButCannotPersistChange
-- staticMemberSyncAsLeaderWithInvalidMemberId
-- testBasicFetchTxnOffsets
-- testBatchLeaveDeadGroup
-- testCommitAndFetchOffsetsWithEmptyGroup
-- testCommitMaintainsSession
-- testCommitOffsetFromUnknownGroup
-- testCommitOffsetInCompletingRebalance
-- testCommitOffsetInCompletingRebalanceFromIllegalGeneration
-- testCommitOffsetInCompletingRebalanceFromUnknownMemberId
-- testCommitOffsetWithDefaultGeneration
-- testCommitOffsetsAfterGroupIsEmpty
-- testCompleteHeartbeatWithGroupDead
-- testCompleteHeartbeatWithMemberAlreadyRemoved
-- testDeleteEmptyGroup
-- testDeleteEmptyGroupWithStoredOffsets
-- testDeleteGroupWithInvalidGroupId
-- testDeleteGroupWithWrongCoordinator
-- testDeleteNonEmptyGroup
-- testDeleteOffsetOfConsumerGroupWithUnparsableProtocol
-- testDeleteOffsetOfDeadConsumerGroup
-- testDeleteOffsetOfEmptyConsumerGroup
-- testDeleteOffsetOfEmptyNonConsumerGroup
-- testDeleteOffsetOfNonEmptyNonConsumerGroup
-- testDeleteOffsetOfNonExistingGroup
-- testDeleteOffsetOfStableConsumerGroup
-- testDescribeGroupInactiveGroup
-- testDescribeGroupRebalancing
-- testDescribeGroupStableForDynamicMember
-- testDescribeGroupStableForStaticMember
-- testDescribeGroupWrongCoordinator
-- testDynamicMembersCanReJoinGroupWithMaxSizeWhileRebalancing
-- testDynamicMembersJoinGroupWithMaxSize
-- testDynamicMembersJoinGroupWithMaxSizeAndRequiredKnownMember
-- testFetchAllOffsets
-- testFetchOffsetForUnknownPartition
-- testFetchOffsetNotCoordinatorForGroup
-- testFetchOffsets
-- testFetchPendingTxnOffsetsWithAbort
-- testFetchPendingTxnOffsetsWithCommit
-- testFetchTxnOffsetsIgnoreSpuriousCommit
-- testFetchTxnOffsetsMultipleProducersOneGroup
-- testFetchTxnOffsetsOneProducerMultipleGroups
-- testFetchTxnOffsetsWithAbort
-- testGenerationIdIncrementsOnRebalance
-- testHeartbeatDeadGroup
-- testHeartbeatDuringRebalanceCausesRebalanceInProgress
-- testHeartbeatEmptyGroup
-- testHeartbeatIllegalGeneration
-- testHeartbeatMaintainsSession
-- testHeartbeatRebalanceInProgress
-- testHeartbeatUnknownConsumerExistingGroup
-- testHeartbeatUnknownGroup
-- testHeartbeatWrongCoordinator
-- testInvalidGroupId
-- testJoinGroupCompletionWhenPendingMemberJoins
-- testJoinGroupCompletionWhenPendingMemberTimesOut
-- testJoinGroupFromUnchangedFollowerDoesNotRebalance
-- testJoinGroupFromUnchangedLeaderShouldRebalance
-- testJoinGroupInconsistentGroupProtocol
-- testJoinGroupInconsistentProtocolType
-- testJoinGroupProtocolTypeIsNotProvidedWhenAnErrorOccurs
-- testJoinGroupReturnsTheProtocolType
-- testJoinGroupSecondJoinInconsistentProtocol
-- testJoinGroupSessionTimeoutTooLarge
-- testJoinGroupSessionTimeoutTooSmall
-- testJoinGroupShouldReceiveErrorIfGroupOverMaxSize
-- testJoinGroupUnknownConsumerExistingGroup
-- testJoinGroupUnknownConsumerNewDeadGroup
-- testJoinGroupUnknownConsumerNewGroup
-- testJoinGroupWithEmptyGroupProtocol
-- testJoinGroupWithEmptyProtocolType
-- testJoinGroupWrongCoordinator
-- testLastJoiningMembersAreKickedOutWhenReJoiningGroupWithMaxSize
-- testLeaderFailToRejoinBeforeFinalRebalanceTimeoutWithLongSessionTimeout
-- testLeaderFailureInSyncGroup
-- testLeaderRejoinBeforeFinalRebalanceTimeoutWithLongSessionTimeout
-- testLeaveGroupStaticMemberWithUnknownMemberId
-- testLeaveGroupUnknownConsumerExistingGroup
-- testLeaveGroupUnknownGroup
-- testLeaveGroupWithFencedInstanceId
-- testLeaveGroupWrongCoordinator
-- testListGroupsIncludesRebalancingGroups
-- testListGroupsIncludesStableGroups
-- testListGroupsWithStates
-- testListGroupsWithTypes
-- testManualCommitOffsetShouldNotValidateMemberIdAndInstanceId
-- testNewMemberFailureAfterJoinGroupCompletion
-- testNewMemberFailureAfterSyncGroupCompletion
-- testNewMemberJoinExpiration
-- testNewMemberTimeoutCompletion
-- testOffsetCommitDeadGroup
-- testOffsetsRetentionMsIntegerOverflow
-- testPendingMemberBatchLeaveGroup
-- testPendingMembersLeavesGroup
-- testRebalanceCompletesBeforeMemberJoins
-- testRebalanceDoesNotTimeOutWhenAllSyncAreReceived
-- testRebalanceTimesOutWhenSyncRequestIsNotReceived
-- testRebalanceTimesOutWhenSyncRequestIsNotReceivedFromFollowers
-- testRebalanceTimesOutWhenSyncRequestIsNotReceivedFromLeaders
-- testRequestHandlingWhileLoadingInProgress
-- testSecondMemberPartiallyJoinAndTimeout
-- testSessionTimeout
-- testSessionTimeoutDuringRebalance
-- testSingleLeaveDeadGroup
-- testStaticMemberFollowerFailToRejoinBeforeRebalanceTimeout
-- testStaticMemberLeaderFailToRejoinBeforeRebalanceTimeout
-- testStaticMembersFencedInstanceBatchLeaveGroup
-- testStaticMembersJoinGroupWithMaxSize
-- testStaticMembersUnknownGroupBatchLeaveGroup
-- testStaticMembersUnknownInstanceBatchLeaveGroup
-- testStaticMembersValidBatchLeaveGroup
-- testStaticMembersWrongCoordinatorBatchLeaveGroup
-- testSyncDeadGroup
-- testSyncGroupEmptyAssignment
-- testSyncGroupFollowerAfterLeader
-- testSyncGroupFromIllegalGeneration
-- testSyncGroupFromUnknownGroup
-- testSyncGroupFromUnknownMember
-- testSyncGroupLeaderAfterFollower
-- testSyncGroupNotCoordinator
-- testSyncGroupReturnsAnErrorWhenProtocolNameIsInconsistent
-- testSyncGroupReturnsAnErrorWhenProtocolTypeIsInconsistent
-- testSyncGroupSucceedWhenProtocolTypeAndNameAreConsistent
-- testSyncGroupSucceedWhenProtocolTypeAndNameAreNotProvided
-- testTxnCommitOffsetWithFencedInstanceId
-- testTxnCommitOffsetWithIllegalGeneration
-- testTxnCommitOffsetWithInvalidMemberId
-- testTxnCommitOffsetWithKnownMemberId
-- testTxnCommitOffsetWithLegalGeneration
-- testTxnOffsetMetadataTooLarge
-- testValidHeartbeat
-- testValidJoinGroup
-- testValidLeaveGroup
-- testVerificationErrorsForTxnOffsetCommits
-kafka.coordinator.group.GroupMetadataManagerTest:
-- testAddGroup
-- testCommitOffset
-- testCommitOffsetFailure
-- testCommitOffsetPartialFailure
-- testCommitOffsetWhenCoordinatorHasMoved
-- testCurrentStateTimestampForAllGroupMetadataVersions
-- testDeserializeFutureGroupMetadataValue
-- testDeserializeFutureOffsetCommitValue
-- testDeserializeHighestSupportedGroupMetadataValueVersion
-- testDeserializeHighestSupportedOffsetCommitValueVersion
-- testDoNotLoadAbortedTransactionalOffsetCommits
-- testExpireGroupWithOffsetsOnly
-- testExpireOffset
-- testGroupLoadWithConsumerAndTransactionalOffsetCommitsConsumerWins
-- testGroupLoadWithConsumerAndTransactionalOffsetCommitsTransactionWins
-- testGroupLoadedWithPendingCommits
-- testGroupMetadataRemoval
-- testGroupMetadataRemovalWithLogAppendTime
-- testGroupNotExists
-- testLoadConsumerGroup
-- testLoadConsumerGroupWithFaultyConsumerProtocol
-- testLoadEmptyConsumerGroup
-- testLoadEmptyGroupWithOffsets
-- testLoadGroupAndOffsetsFromDifferentSegments
-- testLoadGroupAndOffsetsWithCorruptedLog
-- testLoadGroupWithLargeGroupMetadataRecord
-- testLoadGroupWithTombstone
-- testLoadGroupsAndOffsetsWillIgnoreUnknownMessage
-- testLoadOffsetFromOldCommit
-- testLoadOffsetWithExplicitRetention
-- testLoadOffsetsAndGroup
-- testLoadOffsetsAndGroupIgnored
-- testLoadOffsetsWithEmptyControlBatch
-- testLoadOffsetsWithTombstones
-- testLoadOffsetsWithoutGroup
-- testLoadTransactionalOffsetCommitsFromMultipleProducers
-- testLoadTransactionalOffsetsWithoutGroup
-- testLoadWithCommittedAndAbortedAndPendingTransactionalOffsetCommits
-- testLoadWithCommittedAndAbortedTransactionalOffsetCommits
-- testLogInfoFromCleanupGroupMetadata
-- testMetrics
-- testOffsetExpirationOfActiveGroupSemantics
-- testOffsetExpirationOfSimpleConsumer
-- testOffsetExpirationSemantics
-- testOffsetMetadataTooLarge
-- testOffsetMetadataTooLargePartialFailure
-- testOffsetWriteAfterGroupRemoved
-- testPartitionLoadMetric
-- testReadFromOldGroupMetadata
-- testReadMessageKeyCanReadUnknownMessage
-- testSerdeOffsetCommitValue
-- testSerdeOffsetCommitValueWithExpireTimestamp
-- testSerdeOffsetCommitValueWithNoneExpireTimestamp
-- testSerializeGroupMetadataValueToHighestNonFlexibleVersion
-- testSerializeOffsetCommitValueToHighestNonFlexibleVersion
-- testShouldThrowExceptionForUnsupportedGroupMetadataVersion
-- testStoreEmptyGroup
-- testStoreEmptySimpleGroup
-- testStoreGroupErrorMapping
-- testStoreNonEmptyGroup
-- testStoreNonEmptyGroupWhenCoordinatorHasMoved
-- testTransactionalCommitOffsetAborted
-- testTransactionalCommitOffsetAppendFailure
-- testTransactionalCommitOffsetCommitted
-- testTransactionalCommitOffsetWithOffsetMetadataTooLargePartialFailure
-- testUnloadOffsetsAndGroup
-- testUnloadOffsetsAndGroupIgnored
-- testUnloadOffsetsAndGroupIgnoredAfterStopReplica
-- testloadGroupWithStaticMember
-kafka.coordinator.group.GroupMetadataTest:
-- testAwaitingRebalanceToAwaitingRebalanceIllegalTransition
-- testAwaitingRebalanceToPreparingRebalanceTransition
-- testAwaitingRebalanceToStableTransition
-- testCanAddAndRemovePendingSyncMember
-- testCanRebalanceWhenCompletingRebalance
-- testCanRebalanceWhenStable
-- testCannotAddPendingMemberIfStable
-- testCannotAddPendingSyncOfUnknownMember
-- testCannotAddStaticMemberIfAlreadyPresent
-- testCannotRebalanceWhenDead
-- testCannotRebalanceWhenPreparingRebalance
-- testCannotRemovePendingSyncOfUnknownMember
-- testConsumerBeatsTransactionalOffsetCommit
-- testDeadToAwaitingRebalanceIllegalTransition
-- testDeadToDeadIllegalTransition
-- testDeadToPreparingRebalanceIllegalTransition
-- testDeadToStableIllegalTransition
-- testEmptyToAwaitingRebalanceIllegalTransition
-- testEmptyToDeadTransition
-- testEmptyToStableIllegalTransition
-- testFailedTxnOffsetCommitLeavesNoPendingState
-- testHasPendingNonTxnOffsets
-- testHasPendingTxnOffsets
-- testInitNextGeneration
-- testInitNextGenerationEmptyGroup
-- testInvokeJoinCallback
-- testInvokeJoinCallbackFails
-- testInvokeSyncCallback
-- testInvokeSyncCallbackFails
-- testNewGenerationClearsPendingSyncMembers
-- testNotInvokeJoinCallback
-- testNotInvokeSyncCallback
-- testOffsetCommit
-- testOffsetCommitFailure
-- testOffsetCommitFailureWithAnotherPending
-- testOffsetCommitWithAnotherPending
-- testOffsetRemovalDuringTransitionFromEmptyToNonEmpty
-- testPreparingRebalanceToDeadTransition
-- testPreparingRebalanceToEmptyTransition
-- testPreparingRebalanceToPreparingRebalanceIllegalTransition
-- testPreparingRebalanceToStableIllegalTransition
-- testRemovalFromPendingAfterMemberIsStable
-- testRemovalFromPendingSyncWhenMemberIsRemoved
-- testRemovalFromPendingWhenMemberIsRemoved
-- testReplaceGroupInstance
-- testReplaceGroupInstanceWithNonExistingMember
-- testSelectProtocol
-- testSelectProtocolChoosesCompatibleProtocol
-- testSelectProtocolRaisesIfNoMembers
-- testStableToDeadTransition
-- testStableToPreparingRebalanceTransition
-- testStableToStableIllegalTransition
-- testSubscribedTopics
-- testSubscribedTopicsNonConsumerGroup
-- testSupportsProtocols
-- testTransactionBeatsConsumerOffsetCommit
-- testTransactionalCommitIsAbortedAndConsumerCommitWins
-- testUpdateMember
-kafka.coordinator.group.MemberMetadataTest:
-- testHasValidGroupInstanceId
-- testMatchesSupportedProtocols
-- testMetadata
-- testMetadataRaisesOnUnsupportedProtocol
-- testVoteForPreferredProtocol
-- testVoteRaisesOnNoSupportedProtocols
-kafka.coordinator.transaction.ProducerIdManagerTest:
-- testExceedProducerIdLimitZk
-- testGetProducerIdZk
-kafka.coordinator.transaction.ProducerIdsIntegrationTest:
-- testUniqueProducerIds
-kafka.coordinator.transaction.TransactionCoordinatorConcurrencyTest:
-- testConcurrentContinuingInitProducerIdRequests
-- testConcurrentGoodPathSequence
-- testConcurrentGoodPathWithConcurrentPartitionLoading
-- testConcurrentInitProducerIdRequestsOneNewOneContinuing
-- testConcurrentInitProducerIdRequestsWithRetry
-- testConcurrentInitProducerRequestsAtPidBoundary
-- testConcurrentInitProducerRequestsWithRetryAtPidBoundary
-- testConcurrentLoadUnloadPartitions
-- testConcurrentNewInitProducerIdRequests
-- testConcurrentRandomSequences
-- testConcurrentTransactionExpiration
-kafka.coordinator.transaction.TransactionCoordinatorTest:
-- TestEndTxnRequestWhenEmptyTransactionStateForAbortInV1
-- TestEndTxnRequestWhenEmptyTransactionStateForAbortInV2
-- TestEndTxnRequestWhenEmptyTransactionStateForCommitInV2
-- shouldAbortExpiredTransactionsInOngoingStateAndBumpEpoch
-- shouldAbortTransactionOnHandleInitPidWhenExistingTransactionInOngoingState
-- shouldAcceptInitPidAndReturnNextPidWhenTransactionalIdIsNull
-- shouldAppendNewMetadataToLogOnAddPartitionsWhenPartitionsAdded
-- shouldAppendPrepareAbortToLogOnEndTxnWhenStatusIsOngoingAndResultIsAbort
-- shouldAppendPrepareCommitToLogOnEndTxnWhenStatusIsOngoingAndResultIsCommit
-- shouldFailToAbortTransactionOnHandleInitPidWhenProducerEpochIsSmaller
-- shouldGenerateNewProducerIdIfEpochsExhausted
-- shouldGenerateNewProducerIdIfNoStateAndProducerIdAndEpochProvided
-- shouldIncrementEpochAndUpdateMetadataOnHandleInitPidWhenExistingCompleteCommitTransaction
-- shouldIncrementEpochAndUpdateMetadataOnHandleInitPidWhenExistingCompleteTransaction
-- shouldIncrementEpochAndUpdateMetadataOnHandleInitPidWhenExistingEmptyTransaction
-- shouldInitPidWithEpochZeroForNewTransactionalId
-- shouldNotAbortExpiredTransactionsThatHaveAPendingStateTransition
-- shouldNotAcceptSmallerEpochDuringTransactionExpiration
-- shouldNotBumpEpochWhenAbortingExpiredTransactionIfAppendToLogFails
-- shouldNotBumpEpochWithPendingTransaction
-- shouldNotRepeatedlyBumpEpochDueToInitPidDuringOngoingTxnIfAppendToLogFails
-- shouldRemoveTransactionsForPartitionOnEmigration
-- shouldReplyWithInvalidPidMappingOnEndTxnWhenPidDosentMatchMapped
-- shouldReplyWithInvalidPidMappingOnEndTxnWhenTxnIdDoesntExist
-- shouldReplyWithProducerFencedOnEndTxnWhenEpochIsNotSameAsTransaction
-- shouldRespondWithConcurrentTransactionOnAddPartitionsWhenStateIsPrepareAbort
-- shouldRespondWithConcurrentTransactionsOnAddPartitionsWhenStateIsPrepareCommit
-- shouldRespondWithCoordinatorLoadInProgressOnAddPartitionsWhenCoordinatorLoading
-- shouldRespondWithCoordinatorLoadInProgressOnEndTxnWhenCoordinatorIsLoading
-- shouldRespondWithCoordinatorLoadInProgressOnInitPidWhenCoordinatorLoading
-- shouldRespondWithErrorsNoneOnAddPartitionWhenNoErrorsAndPartitionsTheSame
-- shouldRespondWithErrorsNoneOnAddPartitionWhenOngoingVerifyOnlyAndPartitionsTheSame
-- shouldRespondWithInvalidPidMappingOnAddPartitionsToTransactionWhenTransactionalIdNotPresent
-- shouldRespondWithInvalidRequestAddPartitionsToTransactionWhenTransactionalIdIsEmpty
-- shouldRespondWithInvalidRequestAddPartitionsToTransactionWhenTransactionalIdIsNull
-- shouldRespondWithInvalidRequestOnEndTxnWhenTransactionalIdIsEmpty
-- shouldRespondWithInvalidRequestOnEndTxnWhenTransactionalIdIsNull
-- shouldRespondWithInvalidTxnStateWhenVerifyOnlyAndPartitionNotPresent
-- shouldRespondWithNotCoordinatorOnAddPartitionsWhenNotCoordinator
-- shouldRespondWithNotCoordinatorOnEndTxnWhenIsNotCoordinatorForId
-- shouldRespondWithNotCoordinatorOnInitPidWhenNotCoordinator
-- shouldRespondWithProducerFencedOnAddPartitionsWhenEpochsAreDifferent
-- shouldRespondWithSuccessOnAddPartitionsWhenStateIsCompleteAbort
-- shouldRespondWithSuccessOnAddPartitionsWhenStateIsCompleteCommit
-- shouldRespondWithSuccessOnAddPartitionsWhenStateIsOngoing
-- shouldReturnConcurrentTransactionsOnEndTxnRequestWhenStatusIsPrepareCommit
-- shouldReturnInvalidEpochOnEndTxnWhenEpochIsLarger
-- shouldReturnInvalidEpochOnEndTxnWhenEpochIsSmaller
-- shouldReturnInvalidRequestWhenTransactionalIdIsEmpty
-- shouldReturnInvalidTxnRequestOnEndTxnRequestWhenStatusIsCompleteAbortAndResultIsNotAbort
-- shouldReturnInvalidTxnRequestOnEndTxnRequestWhenStatusIsCompleteCommitAndResultIsNotCommit
-- shouldReturnInvalidTxnRequestOnEndTxnRequestWhenStatusIsPrepareAbort
-- shouldReturnInvalidTxnRequestOnEndTxnV2IfNotEndTxnV2Retry
-- shouldReturnOkOnEndTxnV2IfEndTxnV2RetryEpochOverflow
-- shouldReturnOkOnEndTxnWhenStatusIsCompleteAbortAndResultIsAbortInV2
-- shouldUseLastEpochToFenceWhenEpochsAreExhausted
-- shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareAbortState
-- shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareCommitState
-- testDescribeTransactions
-- testDescribeTransactionsWhileCoordinatorLoading
-- testDescribeTransactionsWithEmptyTransactionalId
-- testDescribeTransactionsWithExpiringTransactionalId
-- testEndTxnRequestWhenStatusIsCompleteCommitAndResultIsAbortInV1
-- testEndTxnRequestWhenStatusIsCompleteCommitAndResultIsAbortInV2
-- testEndTxnWhenStatusIsCompleteAbortAndResultIsAbortInV1
-- testEndTxnWhenStatusIsCompleteCommitAndResultIsCommitInV1
-- testEndTxnWhenStatusIsCompleteCommitAndResultIsCommitInV2
-- testFenceProducerWhenMappingExistsWithDifferentProducerId
-- testInitProducerIdStaleCurrentEpochProvided
-- testInitProducerIdWithCurrentEpochProvided
-- testInitProducerIdWithInvalidEpochAfterProducerIdRotation
-- testInitProducerIdWithNoLastProducerData
-- testRetryInitProducerIdAfterProducerIdRotation
-- testVerifyPartitionHandling
-kafka.coordinator.transaction.TransactionLogTest:
-- shouldReadWriteMessages
-- shouldThrowExceptionWriteInvalidTxn
-- testDeserializeFutureTransactionLogValue
-- testDeserializeHighestSupportedTransactionLogValue
-- testReadTxnRecordKeyCanReadUnknownMessage
-- testSerializeTransactionLogValueToFlexibleVersion
-- testSerializeTransactionLogValueToHighestNonFlexibleVersion
-- testTransactionMetadataParsing
-- testTransactionMetadataTombstoneParsing
-kafka.coordinator.transaction.TransactionMarkerChannelManagerTest:
-- shouldAbortAppendToLogOnEndTxnWhenNotCoordinatorError
-- shouldCompleteAppendToLogOnEndTxnWhenSendMarkersSucceed
-- shouldCreateMetricsOnStarting
-- shouldGenerateEmptyMapWhenNoRequestsOutstanding
-- shouldGenerateRequestPerPartitionPerBroker
-- shouldNotLoseTxnCompletionAfterLoad
-- shouldOnlyWriteTxnCompletionOnce
-- shouldRemoveMarkersForTxnPartitionWhenPartitionEmigrated
-- shouldRetryAppendToLogOnEndTxnWhenCoordinatorNotAvailableError
-- shouldSaveForLaterWhenLeaderUnknownButNotAvailable
-- shouldSkipSendMarkersWhenLeaderNotFound
-- testRemoveMetricsOnClose
-kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest:
-- shouldCompleteDelayedOperationWhenCoordinatorEpochChanged
-- shouldCompleteDelayedOperationWhenCoordinatorEpochFenced
-- shouldCompleteDelayedOperationWhenCoordinatorLoading
-- shouldCompleteDelayedOperationWhenInvalidProducerEpoch
-- shouldCompleteDelayedOperationWhenNoErrors
-- shouldCompleteDelayedOperationWhenNotCoordinator
-- shouldReEnqueuePartitionsWhenBrokerDisconnected
-- shouldRemoveTopicPartitionFromWaitingSetOnUnsupportedForMessageFormat
-- shouldRetryPartitionWhenKafkaStorageError
-- shouldRetryPartitionWhenNotEnoughReplicasAfterAppendError
-- shouldRetryPartitionWhenNotEnoughReplicasError
-- shouldRetryPartitionWhenNotLeaderOrFollowerError
-- shouldRetryPartitionWhenUnknownTopicOrPartitionError
-- shouldThrowIllegalStateExceptionIfErrorCodeNotAvailableForPid
-- shouldThrowIllegalStateExceptionWhenCorruptMessageError
-- shouldThrowIllegalStateExceptionWhenInvalidRequiredAcksError
-- shouldThrowIllegalStateExceptionWhenMessageTooLargeError
-- shouldThrowIllegalStateExceptionWhenRecordListTooLargeError
-- shouldThrowIllegalStateExceptionWhenUnknownError
-kafka.coordinator.transaction.TransactionMetadataTest:
-- testAllTransactionStatesAreMapped
-- testAttemptedEpochBumpWithFencedEpoch
-- testAttemptedEpochBumpWithLastEpoch
-- testAttemptedEpochBumpWithNewlyCreatedMetadata
-- testBumpEpochNotAllowedIfEpochsExhausted
-- testEpochBumpOnEndTxn
-- testEpochBumpOnEndTxnOverflow
-- testEpochBumpWithCurrentEpochProvided
-- testFenceProducerAfterEpochsExhausted
-- testFenceProducerNotAllowedIfItWouldOverflow
-- testInitializeEpoch
-- testInvalidTransitionFromCompleteAbortToFence
-- testInvalidTransitionFromCompleteCommitToFence
-- testNormalEpochBump
-- testRotateProducerId
-- testRotateProducerIdInOngoingState
-- testRotateProducerIdInPrepareAbortState
-- testRotateProducerIdInPrepareCommitState
-- testTolerateTimeShiftDuringAddPartitions
-- testTolerateTimeShiftDuringCompleteAbort
-- testTolerateTimeShiftDuringCompleteCommit
-- testTolerateTimeShiftDuringPrepareAbort
-- testTolerateTimeShiftDuringPrepareCommit
-- testTolerateUpdateTimeResetDuringProducerIdRotation
-- testTolerateUpdateTimeShiftDuringEpochBump
-- testTransactionStateIdAndNameMapping
-- testTransitFromCompleteAbortToPrepareAbortInV2
-- testTransitFromCompleteCommitToPrepareAbortInV2
-- testTransitFromEmptyToPrepareAbortInV2
kafka.coordinator.transaction.TransactionStateManagerTest:
-- shouldNotRemoveExpiredTransactionalIdsIfLogAppendFails
-- shouldNotRemoveOngoingTransactionalIds
-- shouldNotRemovePrepareAbortTransactionalIds
-- shouldNotRemovePrepareCommitTransactionalIds
-- shouldOnlyConsiderTransactionsInTheOngoingStateToAbort
-- shouldRemoveCompleteAbortExpiredTransactionalIds
-- shouldRemoveCompleteCommitExpiredTransactionalIds
-- shouldRemoveEmptyExpiredTransactionalIds
-- shouldReturnNotCoordinatorErrorIfTransactionIdPartitionNotOwned
-- shouldWriteTxnMarkersForTransactionInPreparedAbortState
-- shouldWriteTxnMarkersForTransactionInPreparedCommitState
-- testAddGetPids
-- testAppendFailToCoordinatorLoadingError
-- testAppendFailToCoordinatorNotAvailableError
-- testAppendFailToNotCoordinatorError
-- testAppendFailToUnknownError
-- testAppendTransactionToLogWhilePendingStateChanged
-- testAppendTransactionToLogWhileProducerFenced
-- testCompleteTransitionWhenAppendSucceeded
-- testDeleteLoadingPartition
-- testDeletePartition
-- testIgnoreUnknownRecordType
-- testListTransactionsFiltering
-- testListTransactionsWithCoordinatorLoadingInProgress
-- testLoadAndRemoveTransactionsForPartition
-- testLoadTransactionMetadataContainingSegmentEndingWithEmptyBatch
-- testLoadTransactionMetadataWithCorruptedLog
- testMakeFollowerLoadingPartition
-- testPartitionLoadMetric
-- testPendingStateNotResetOnRetryAppend
-- testSuccessfulReimmigration
-- testTransactionExpirationShouldNotFailWithUninitializedTransactionMetadata
-- testTransactionExpirationShouldRespectBatchSize
-- testTransactionVersionInTransactionManager
-- testTransactionalExpirationWithOfflineLogDir
-- testTransactionalExpirationWithTooSmallBatchSize
-- testValidateTransactionTimeout
-kafka.docker.KafkaDockerWrapperTest:
-- testFormatStorageCmd
-- testGetLog4jConfigsFromEnv
-- testGetLog4jConfigsFromEnvInvalidEnvVariable
-- testGetLog4jConfigsFromEnvWithEmptyEnvVariable
-- testGetServerConfigsFromEnv
-- testGetToolsLog4jConfigsFromEnv
-- testGetToolsLog4jConfigsFromEnvInvalidEnvVariable
-- testGetToolsLog4jConfigsFromEnvWithEmptyEnvVariable
-- testPrepareLog4jConfigs
-- testPrepareLog4jConfigsWithoutEnvVariables
-- testPrepareLog4jConfigsWithoutMountedFile
-- testPrepareServerConfigs
-- testPrepareServerConfigsWithEmptyMountedFile
-- testPrepareServerConfigsWithoutEnvVariables
-- testPrepareServerConfigsWithoutMountedFile
-- testPrepareServerConfigsWithoutUserInput
-- testPrepareToolsLog4jConfigs
-- testPrepareToolsLog4jConfigsWithoutEnvVariable
-- testPrepareToolsLog4jConfigsWithoutMountedFile
-kafka.integration.MetricsDuringTopicCreationDeletionTest:
-- testMetricsDuringTopicCreateDelete
-kafka.integration.MinIsrConfigTest:
-- testDefaultKafkaConfig
-kafka.integration.UncleanLeaderElectionTest:
-- testTopicUncleanLeaderElectionEnableWithAlterTopicConfigs
-- testUncleanLeaderElectionDisabled
-- testUncleanLeaderElectionDisabledByTopicOverride
-- testUncleanLeaderElectionEnabled
-- testUncleanLeaderElectionEnabledByTopicOverride
-- testUncleanLeaderElectionInvalidTopicOverride
-kafka.log.BrokerCompressionTest:
-- testBrokerSideCompression
-kafka.log.LogCleanerIntegrationTest:
-- testIsThreadFailed
-- testMarksPartitionsAsOfflineAndPopulatesUncleanableMetrics
-- testMaxLogCompactionLag
-kafka.log.LogCleanerLagIntegrationTest:
-- cleanerTest
-kafka.log.LogCleanerManagerTest:
-- testAlterCheckpointDirShouldRemoveDataInSrcDirAndAddInNewDir
-- testCheckpointUpdatedForInvalidOffsetNoCleaning
-- testCheckpointUpdatedForInvalidOffsetNotSelected
-- testCleanableOffsetsActiveSegment
-- testCleanableOffsetsForNone
-- testCleanableOffsetsForShortTime
-- testCleanableOffsetsForTime
-- testCleanableOffsetsNeedsCheckpointReset
-- testConcurrentLogCleanupAndLogTruncation
-- testConcurrentLogCleanupAndTopicDeletion
-- testDirtyOffsetLargerThanActiveSegmentBaseOffset
-- testDirtyOffsetResetIfLargerThanEndOffset
-- testDirtyOffsetResetIfSmallerThanStartOffset
-- testDoneCleaning
-- testDoneDeleting
-- testGrabFilthiestCompactedLogIgnoresBothInProgressPartitionsAndUncleanablePartitions
-- testGrabFilthiestCompactedLogIgnoresInProgressPartitions
-- testGrabFilthiestCompactedLogIgnoresUncleanablePartitions
-- testGrabFilthiestCompactedLogReturnsLogWithDirtiestRatio
-- testGrabFilthiestCompactedLogThrowsException
-- testHandleLogDirFailureShouldRemoveDirAndData
-- testLogStartOffsetLargerThanActiveSegmentBaseOffset
-- testLogsUnderCleanupIneligibleForCompaction
-- testLogsWithSegmentsToDeleteShouldConsiderCleanupPolicyCompactDeleteLogs
-- testLogsWithSegmentsToDeleteShouldConsiderCleanupPolicyCompactLogs
-- testLogsWithSegmentsToDeleteShouldNotConsiderCleanupPolicyDeleteLogs
-- testLogsWithSegmentsToDeleteShouldNotConsiderUncleanablePartitions
-- testMaybeTruncateCheckpointShouldTruncateData
-- testUndecidedTransactionalDataNotCleanable
-- testUpdateCheckpointsShouldAddOffsetToPartition
-- testUpdateCheckpointsShouldRemovePartitionData
-kafka.log.LogCleanerParameterizedIntegrationTest:
-- cleanerConfigUpdateTest
-- cleanerTest
-- testCleanerWithMessageFormatV0
-- testCleaningNestedMessagesWithV0AndV1
-- testCleansCombinedCompactAndDeleteTopic
-kafka.log.LogCleanerTest:
-- testAbortMarkerRemoval
-- testAbortMarkerRetentionWithEmptyBatch
-- testAbortedTransactionSpanningSegments
-- testBasicTransactionAwareCleaning
-- testBuildOffsetMap
-- testBuildOffsetMapFakeLarge
-- testBuildPartialOffsetMap
-- testCleanCorruptMessageSet
-- testCleanEmptyControlBatch
-- testCleanSegments
-- testCleanSegmentsRetainingLastEmptyBatch
-- testCleanSegmentsWithAbort
-- testCleanSegmentsWithConcurrentSegmentDeletion
-- testCleanTombstone
-- testCleanWithTransactionsSpanningSegments
-- testCleaningBeyondMissingOffsets
-- testCleaningWithDeletes
-- testCleaningWithKeysConflictingWithTxnMarkerKeys
-- testCleaningWithUncleanableSection
-- testCleaningWithUnkeyedMessages
-- testClientHandlingOfCorruptMessageSet
-- testCommitMarkerRemoval
-- testCommitMarkerRetentionWithEmptyBatch
-- testCommittedTransactionSpanningSegments
-- testCorruptMessageSizeLargerThanBytesAvailable
-- testDeletedBatchesWithNoMessagesRead
-- testDuplicateCheckAfterCleaning
-- testEmptyBatchRemovalWithSequenceReuse
-- testLargeMessage
-- testLogCleanerRetainsLastSequenceEvenIfTransactionAborted
-- testLogCleanerRetainsProducerLastSequence
-- testLogCleanerStats
-- testLogToClean
-- testLogToCleanWithUncleanableSection
-- testMaxCleanTimeSecs
-- testMessageLargerThanMaxMessageSize
-- testMessageLargerThanMaxMessageSizeWithCorruptHeader
-- testMetricsActiveAfterReconfiguration
-- testMultiPassSegmentCleaningWithAbortedTransactions
-- testPartialSegmentClean
-- testReconfigureLogCleanerIoMaxBytesPerSecond
-- testRecoveryAfterCrash
-- testRemoveMetricsOnClose
-- testSegmentGrouping
-- testSegmentGroupingFollowingLoadOfZeroIndex
-- testSegmentGroupingWithSparseOffsets
-- testSegmentGroupingWithSparseOffsetsAndEmptySegments
-- testSegmentWithOffsetOverflow
-- testSizeTrimmedForPreallocatedAndCompactedTopic
-kafka.log.LogConcurrencyTest:
-- testUncommittedDataNotConsumed
-- testUncommittedDataNotConsumedFrequentSegmentRolls
-kafka.log.LogConfigTest:
-- ensureNoStaticInitializationOrderDependency
-- shouldValidateThrottledReplicasConfig
-- testDisableRemoteLogStorage
-- testEnableRemoteLogStorage
-- testEnableRemoteLogStorageOnCompactedTopic
-- testFromPropsInvalid
-- testGetConfigValue
-- testInValidRemoteConfigsInZK
-- testInvalidCompactionLagConfig
-- testInvalidLocalLogRetentionProps
-- testKafkaConfigToProps
-- testLocalLogRetentionDerivedDefaultProps
-- testLocalLogRetentionDerivedProps
-- testLocalLogRetentionProps
-- testOverriddenConfigsAsLoggableString
-- testToEnrichedRst
-- testToHtml
-- testToHtmlTable
-- testToRst
-- testTopicCreationWithInvalidRetentionSize
-- testTopicCreationWithInvalidRetentionTime
-- testValidRemoteLogCopyDisabled
-- testValidRemoteLogDeleteOnDisable
-- testValidateBrokerLogConfigs
-- testValidateWithMetadataVersionJbodSupport
-kafka.log.LogLoaderTest:
-- testBogusIndexSegmentsAreRemoved
-- testCleanShutdownFile
-- testCorruptIndexRebuild
-- testCorruptLog
-- testCorruptedLogRecoveryDoesNotDeleteProducerStateSnapshotsPostRecovery
-- testFullTransactionIndexRecovery
-- testIndexRebuild
-- testLeaderEpochCacheClearedAfterStaticMessageFormatDowngrade
-- testLoadProducersAfterDeleteRecordsMidSegment
-- testLoadProducersAfterDeleteRecordsOnSegment
-- testLoadingLogKeepsLargestStrayProducerStateSnapshot
-- testLogEndLessThanStartAfterReopen
-- testLogRecoversForLeaderEpoch
-- testLogRecoversToCorrectOffset
-- testLogRecoveryIsCalledUponBrokerCrash
-- testLogStartOffsetWhenRemoteStorageIsEnabled
-- testOpenDeletesObsoleteFiles
-- testOverCompactedLogRecovery
-- testOverCompactedLogRecoveryMultiRecord
-- testOverCompactedLogRecoveryMultiRecordV1
-- testProducerSnapshotsRecoveryAfterUncleanShutdownCurrentMessageFormat
-- testProducerSnapshotsRecoveryAfterUncleanShutdownV1
-- testRebuildTimeIndexForOldMessages
-- testRecoverAfterNonMonotonicCoordinatorEpochWrite
-- testRecoverLastSegmentWithNoSnapshots
-- testRecoverOnlyLastSegment
-- testRecoverWithEmptyActiveSegment
-- testRecoveryAfterCrashDuringSplitPhase1
-- testRecoveryAfterCrashDuringSplitPhase2
-- testRecoveryAfterCrashDuringSplitPhase3
-- testRecoveryAfterCrashDuringSplitPhase4
-- testRecoveryAfterCrashDuringSplitPhase5
-- testRecoveryOfSegmentWithOffsetOverflow
-- testReopenThenTruncate
-- testSkipLoadingIfEmptyProducerStateBeforeTruncation
-- testSkipTruncateAndReloadIfNewMessageFormatAndCleanShutdown
-- testSkipTruncateAndReloadIfOldMessageFormatAndCleanShutdown
-- testSkipTruncateAndReloadIfOldMessageFormatAndNoCleanShutdown
-kafka.log.LogManagerTest:
-- testBrokerConfigChangeDeliveredToAllLogs
-- testCheckpointForOnlyAffectedLogs
-- testCheckpointLogStartOffsetForNormalTopic
-- testCheckpointLogStartOffsetForRemoteTopic
-- testCheckpointRecoveryPoints
-- testCleanShutdownFileWhenShutdownCalledBeforeStartupComplete
-- testCleanShutdownFileWithBrokerEpoch
-- testCleanupExpiredSegments
-- testCleanupSegmentsToMaintainSize
-- testConfigChangeGetsCleanedUp
-- testConfigChangesWithNoLogGettingInitialized
-- testCreateAndDeleteOverlyLongTopic
-- testCreateLog
-- testCreateLogOnTargetedLogDirectory
-- testCreateLogWithInvalidLogDir
-- testCreateLogWithLogDirFallback
-- testCreateLogWithTargetedLogDirectorySetAsUnassigned
-- testCreateLogWithTargetedLogDirectorySetAsUnknownWithoutAnyOfflineDirectories
-- testDoesntCleanLogsWithCompactDeletePolicy
-- testDoesntCleanLogsWithCompactPolicy
-- testFileReferencesAfterAsyncDelete
-- testFindNoStrayReplicasInFullLAIR
-- testFindSomeStrayReplicasInFullLAIR
-- testFindStrayReplicasInEmptyLAIR
-- testGetNonExistentLog
-- testHandlingExceptionsDuringShutdown
-- testInvalidLogDirNotFailLogManager
-- testIsStrayKraftMissingTopicId
-- testIsStrayKraftReplicaInImage
-- testIsStrayKraftReplicaInImageWithRemoteReplicas
-- testIsStrayKraftReplicaWithEmptyImage
-- testLeastLoadedAssignment
-- testLoadDirectoryIds
-- testLoadLogRenameLogThatShouldBeStray
-- testLoadLogsSkipRemoteIndexCache
-- testLock
-- testLogRecoveryMetrics
-- testLogRecoveryMetricsShouldBeRemovedAfterLogRecovered
-- testMetricsAreRemovedWhenMovingCurrentToFutureLog
-- testMetricsExistWhenLogIsRecreatedBeforeDeletion
-- testRecoveryDirectoryMappingWithRelativeDirectory
-- testRecoveryDirectoryMappingWithTrailingSlash
-- testShutdownWithZeroFileDeleteDelayMs
-- testTimeBasedFlush
-- testTopicConfigChangeStopCleaningIfCompactIsRemoved
-- testTopicConfigChangeUpdatesLogConfig
-- testTopicRecreationInFullLAIR
-- testTwoLogManagersUsingSameDirFails
-- testWaitForAllToComplete
-kafka.log.UnifiedLogTest:
-- followerShouldSaveEpochInformationFromReplicatedMessagesToTheEpochCache
-- shouldApplyEpochToMessageOnAppendIfLeader
-- shouldDeleteSegmentsReadyToBeDeletedWhenCleanupPolicyIsCompactAndDelete
-- shouldDeleteSizeBasedSegments
-- shouldDeleteStartOffsetBreachedSegmentsWhenPolicyDoesNotIncludeDelete
-- shouldDeleteTimeBasedSegmentsReadyToBeDeleted
-- shouldNotDeleteSegmentsWhenPolicyDoesNotIncludeDelete
-- shouldNotDeleteSizeBasedSegmentsWhenUnderRetentionSize
-- shouldNotDeleteTimeBasedSegmentsWhenNoneReadyToBeDeleted
-- shouldTruncateLeaderEpochCheckpointFileWhenTruncatingLog
-- shouldTruncateLeaderEpochsWhenDeletingSegments
-- shouldUpdateOffsetForLeaderEpochsWhenDeletingSegments
-- testAbortedTransactionSpanningMultipleSegments
-- testActiveProducers
-- testActiveSegmentDeletionDueToRetentionTimeBreachWithRemoteStorage
-- testAllowNonZeroSequenceOnFirstAppendNonZeroEpoch
-- testAppendAndReadWithNonSequentialOffsets
-- testAppendAndReadWithSequentialOffsets
-- testAppendAsLeaderWithRaftLeader
-- testAppendBelowExpectedOffsetThrowsException
-- testAppendEmptyLogBelowLogStartOffsetThrowsException
-- testAppendInfoFirstOffset
-- testAppendMessageWithNullPayload
-- testAppendToOrReadFromLogInFailedLogDir
-- testAppendToTransactionIndexFailure
-- testAppendWithNoTimestamp
-- testAppendWithOutOfOrderOffsetsThrowsException
-- testAsyncDelete
-- testBuildTimeIndexWhenNotAssigningOffsets
-- testCannotDeleteSegmentsAtOrAboveHighWatermark
-- testCannotIncrementLogStartOffsetPastHighWatermark
-- testCompactedTopicConstraints
-- testCompactionDeletesProducerStateSnapshots
-- testCompressedMessages
-- testConvertToOffsetMetadataDoesNotThrowOffsetOutOfRangeError
-- testDegenerateSegmentSplit
-- testDegenerateSegmentSplitWithOutOfRangeBatchLastOffset
-- testDeletableSegmentsFilter
-- testDeletableSegmentsIteration
-- testDeleteOldSegments
-- testDeleteSnapshotsOnIncrementLogStartOffset
-- testDisabledVerificationClearsVerificationGuard
-- testDuplicateAppendToFollower
-- testDuplicateAppends
-- testEmptyTransactionStillClearsVerificationGuard
-- testEnablingVerificationWhenRequestIsAtLogLayer
-- testEndTxnWithFencedProducerEpoch
-- testFetchLatestTieredTimestampNoRemoteStorage
-- testFetchLatestTieredTimestampWithRemoteStorage
-- testFetchOffsetByTimestampFromRemoteStorage
-- testFetchOffsetByTimestampIncludesLeaderEpoch
-- testFetchOffsetByTimestampShouldReadOnlyLocalLogWhenLogIsEmpty
-- testFetchOffsetByTimestampWithMaxTimestampIncludesTimestamp
-- testFetchUpToHighWatermark
-- testFetchUpToLastStableOffset
-- testFetchUpToLogEndOffset
-- testFirstUnstableOffsetNoTransactionalData
-- testFirstUnstableOffsetWithTransactionalData
-- testFlushingEmptyActiveSegments
-- testGetFirstBatchTimestampForSegments
-- testHighWatermarkMaintenance
-- testHighWatermarkMetadataUpdatedAfterSegmentRoll
-- testIncrementLocalLogStartOffsetAfterLocalLogDeletion
-- testIndexResizingAtTruncation
-- testInitializationOfProducerSnapshotsUpgradePath
-- testLastStableOffsetDoesNotExceedLogStartOffsetAfterSegmentDeletion
-- testLastStableOffsetDoesNotExceedLogStartOffsetMidSegment
-- testLastStableOffsetWithMixedProducerData
-- testLeaderEpochCacheClearedAfterDowngradeInAppendedMessages
-- testLeaderEpochCacheClearedAfterDynamicMessageFormatDowngrade
-- testLeaderEpochCacheCreatedAfterMessageFormatUpgrade
-- testLoadEmptyLog
-- testLoadPartitionDirWithNoSegmentsShouldNotThrow
-- testLoadingLogDeletesProducerStateSnapshotsPastLogEndOffset
-- testLogDeletionAfterClose
-- testLogDeletionAfterDeleteRecords
-- testLogFailsWhenInconsistentTopicIdSet
-- testLogFlushesPartitionMetadataOnAppend
-- testLogFlushesPartitionMetadataOnClose
-- testLogOffsetsListener
-- testLogRecoversTopicId
-- testLogReinitializeAfterManualDelete
-- testLogRollAfterLogHandlerClosed
-- testLogRolls
-- testLogSegmentsCallCorrect
-- testLogStartOffsetMovementDeletesSnapshots
-- testMaybeUpdateHighWatermarkAsFollower
-- testMessageSetSizeCheck
-- testMessageSizeCheck
-- testMessageSizeCheckInAppendAsFollower
-- testMultipleProducerIdsPerMemoryRecord
-- testMultipleProducersWithDuplicatesInSingleAppend
-- testNoOpWhenKeepPartitionMetadataFileIsFalse
-- testNoOpWhenRemoteLogStorageIsDisabled
-- testNonSequentialAppend
-- testOffsetFromProducerSnapshotFile
-- testOffsetSnapshot
-- testOldProducerEpoch
-- testPeriodicProducerIdExpiration
-- testProducerExpireCheckAfterDelete
-- testProducerIdExpirationOnSegmentDeletion
-- testProducerIdMapOffsetUpdatedForNonIdempotentData
-- testProducerIdMapTruncateFullyAndStartAt
-- testProducerIdMapTruncateTo
-- testProducerIdMapTruncateToWithNoSnapshots
-- testProducerSnapshotAfterSegmentRollOnAppend
-- testReadAtLogGap
-- testReadCommittedWithConcurrentHighWatermarkUpdates
-- testReadOutOfRange
-- testReadWithMinMessage
-- testReadWithTooSmallMaxLength
-- testRebuildProducerIdMapWithCompactedData
-- testRebuildProducerStateWithEmptyCompactedBatch
-- testRebuildTransactionalState
-- testRecoveryPointNotIncrementedOnProducerStateSnapshotFlushFailure
-- testRemoteLogStorageIsDisabledOnInternalAndRemoteLogMetadataTopic
-- testRenamingDirWithoutReinitialization
-- testRetentionDeletesProducerStateSnapshots
-- testRetentionIdempotency
-- testRetentionOnLocalLogDeletionWhenRemoteLogCopyDisabled
-- testRetentionOnLocalLogDeletionWhenRemoteLogCopyEnabledAndDefaultLocalRetentionBytes
-- testRetentionOnLocalLogDeletionWhenRemoteLogCopyEnabledAndDefaultLocalRetentionMs
-- testRollSegmentThatAlreadyExists
-- testSegmentDeletionEnabledBeforeUploadToRemoteTierWhenLogStartOffsetMovedAhead
-- testSegmentDeletionWithHighWatermarkInitialization
-- testSizeBasedLogRoll
-- testSplitOnOffsetOverflow
-- testStartOffsetsRemoteLogStorageIsEnabled
-- testTakeSnapshotOnRollAndDeleteSnapshotOnRecoveryPointCheckpoint
-- testThatGarbageCollectingSegmentsDoesntChangeOffset
-- testTimeBasedLogRollDuringAppend
-- testTimeBasedLogRollJitter
-- testTopicIdFlushesBeforeDirectoryRename
-- testTopicIdTransfersAfterDirectoryRename
-- testTransactionIndexUpdated
-- testTransactionIndexUpdatedThroughReplication
-- testTransactionIsOngoingAndVerificationGuard
-- testTruncateBelowFirstUnstableOffset
-- testTruncateFullyAndStart
-- testTruncateFullyAndStartBelowFirstUnstableOffset
-- testTruncateTo
-- testTruncateToEndOffsetClearsEpochCache
-- testUpdateLogOffsetsListener
-- testUpdateProducerIdMapWithCompactedData
-- testWriteLeaderEpochCheckpointAfterDirectoryRename
-- testZombieCoordinatorFenced
-- testZombieCoordinatorFencedEmptyTransaction
-kafka.log.remote.RemoteIndexCacheTest:
-- testCacheEntryExpiry
-- testCacheEntryIsDeletedOnRemoval
-- testCleanerThreadShutdown
-- testClearCacheAndIndexFilesWhenResizeCache
-- testClose
-- testCloseIsIdempotent
-- testConcurrentCacheDeletedFileExists
-- testConcurrentReadWriteAccessForCache
-- testConcurrentRemoveReadForCache
-- testCorrectnessForCacheAndIndexFilesWhenResizeCache
-- testCorruptCacheIndexFileExistsButNotInCache
-- testFetchIndexForMissingTransactionIndex
-- testFetchIndexFromRemoteStorage
-- testGetIndexAfterCacheClose
-- testIndexFileAlreadyExistOnDiskButNotInCache
-- testIndexFileNameAndLocationOnDisk
-- testMultipleIndexEntriesExecutionInCorruptException
-- testPositionForNonExistingIndexFromRemoteStorage
-- testRSMReturnCorruptedIndexFile
-- testReloadCacheAfterClose
-- testRemoveItem
-- testRemoveMultipleItems
-- testRemoveNonExistentItem
-kafka.log.remote.RemoteLogManagerTest:
-- testBuildFilteredLeaderEpochMap
-- testCandidateLogSegmentsSkipsActiveSegment
-- testCandidateLogSegmentsSkipsSegmentsAfterLastStableOffset
-- testCopyLogSegmentToRemoteForStaleTopic
-- testCopyLogSegmentsToRemoteShouldCopyExpectedLogSegment
-- testCopyQuota
-- testCopyQuotaManagerConfig
-- testCopyThrottling
-- testCustomMetadataSizeExceedsLimit
-- testDeleteLogSegmentDueToRetentionSizeBreach
-- testDeleteLogSegmentDueToRetentionTimeBreach
-- testDeleteRetentionMsBeingCancelledBeforeSecondDelete
-- testDeleteRetentionMsBiggerThanTimeMs
-- testDeleteRetentionMsOnExpiredSegment
-- testDeletionOnOverlappingRetentionBreachedSegments
-- testDeletionOnRetentionBreachedSegments
-- testDeletionSkippedForSegmentsBeingCopied
-- testEpochEntriesAsByteBuffer
-- testFailedCopyShouldDeleteTheDanglingSegment
-- testFailedDeleteExpiredSegments
-- testFetchNextSegmentWithTxnIndex
-- testFetchOffsetByTimestampWithTieredStorageDoesNotFetchIndexWhenExistsLocally
-- testFetchQuotaManagerConfig
-- testFetchRemoteLogSegmentMetadata
-- testFindHighestRemoteOffset
-- testFindHighestRemoteOffsetOnEmptyRemoteStorage
-- testFindHighestRemoteOffsetWithUncleanLeaderElection
-- testFindLogStartOffset
-- testFindLogStartOffsetFallbackToLocalLogStartOffsetWhenRemoteIsEmpty
-- testFindNextSegmentWithTxnIndex
-- testFindNextSegmentWithTxnIndexTraversesNextEpoch
-- testFindOffsetByTimestamp
-- testFindOffsetByTimestampWithInvalidEpochSegments
-- testFindOffsetByTimestampWithSegmentNotReady
-- testGetClassLoaderAwareRemoteStorageManager
-- testGetLeaderEpochCheckpoint
-- testIdempotentClose
-- testLeadershipChangesWithoutRemoteLogManagerConfiguring
-- testLogStartOffsetUpdatedOnStartup
-- testMetricsUpdateOnCopyLogSegmentsFailure
-- testOnLeadershipChangeWillInvokeHandleLeaderOrFollowerPartitions
-- testRLMOpsWhenMetadataIsNotReady
-- testRLMShutdownDuringQuotaExceededScenario
-- testRLMTaskDoesNotUploadSegmentsWhenRemoteLogMetadataManagerIsNotInitialized
-- testReadForFirstBatchInLogCompaction
-- testReadForFirstBatchMoreThanMaxFetchBytes
-- testReadForMissingFirstBatchInRemote
-- testRemoteDeleteLagsOnRetentionBreachedSegments
-- testRemoteLogManagerRemoteMetrics
-- testRemoteLogManagerTasksAvgIdlePercentAndMetadataCountMetrics
-- testRemoteLogMetadataManagerWithEndpointConfig
-- testRemoteLogMetadataManagerWithEndpointConfigOverridden
-- testRemoteLogMetadataManagerWithUserDefinedConfigs
-- testRemoteLogSizeRetentionShouldFilterOutCopySegmentStartState
-- testRemoteLogTaskUpdateRemoteLogSegmentMetadataAfterLogDirChanged
-- testRemoteReadFetchDataInfo
-- testRemoteSegmentWithinLeaderEpochs
-- testRemoteSegmentWithinLeaderEpochsForOverlappingSegments
-- testRemoteSizeData
-- testRemoteSizeTime
-- testRemoteStorageManagerWithUserDefinedConfigs
-- testRemoveMetricsOnClose
-- testStartup
-- testStopPartitionsWithDeletion
-- testStopPartitionsWithoutDeletion
-- testTierLagResetsToZeroOnBecomingFollower
-- testTopicIdCacheUpdates
-kafka.log.remote.RemoteLogOffsetReaderTest:
-- testReadRemoteLog
-- testTaskQueueFullAndCancelTask
-- testThrowErrorOnFindOffsetByTimestamp
-kafka.log.remote.RemoteLogReaderTest:
-- testRemoteLogReaderWithError
-- testRemoteLogReaderWithoutError
-kafka.metrics.KafkaMetricsGroupTest:
-- testTaggedMetricName
-- testTaggedMetricNameWithEmptyValue
-- testUntaggedMetricName
-kafka.metrics.MetricsTest:
-- testBrokerStateMetric
-- testBrokerTopicMetricsBytesInOut
-- testBrokerTopicMetricsUnregisteredAfterDeletingTopic
-- testClusterIdMetric
-- testGeneralBrokerTopicMetricsAreGreedilyRegistered
-- testJMXFilter
-- testKRaftControllerMetrics
-- testLinuxIoMetrics
-- testMetricsReporterAfterDeletingTopic
-- testSessionExpireListenerMetrics
-- testUpdateJMXFilter
-- testWindowsStyleTagNames
-- testYammerMetricsCountMetric
-kafka.network.ConnectionQuotasTest:
-- testBrokerConnectionRateLimitWhenActualRateAboveLimit
-- testBrokerConnectionRateLimitWhenActualRateBelowLimit
-- testEnforcedIpConnectionRateQuotaUpdate
-- testFailDecrementForUnknownIp
-- testFailWhenNoListeners
-- testIpConnectionRateMetricUpdate
-- testIpConnectionRateWhenActualRateAboveLimit
-- testIpConnectionRateWhenActualRateBelowLimit
-- testIpConnectionRateWithListenerConnectionRate
-- testListenerConnectionRateLimitWhenActualRateAboveLimit
-- testListenerConnectionRateLimitWhenActualRateBelowLimit
-- testMaxBrokerConnectionRateReconfiguration
-- testMaxBrokerWideConnectionLimit
-- testMaxConnectionsPerIp
-- testMaxListenerConnectionLimits
-- testMaxListenerConnectionListenerMustBeAboveZero
-- testMaxListenerConnectionRateReconfiguration
-- testNoConnectionLimitsByDefault
-- testNonDefaultConnectionCountLimitAndRateLimit
-- testRejectedIpConnectionUnrecordedFromConnectionRateQuotas
-kafka.network.DynamicConnectionQuotaTest:
-- testDynamicConnectionQuota
-- testDynamicIpConnectionRateQuota
-- testDynamicListenerConnectionCreationRateQuota
-- testDynamicListenerConnectionQuota
-kafka.network.DynamicNumNetworkThreadsTest:
-- testDynamicNumNetworkThreads
-kafka.network.RequestChannelTest:
-- testAlterRequests
-- testBuildEnvelopeResponse
-- testIncrementalAlterRequests
-- testJsonRequests
-- testNonAlterRequestsNotTransformed
-kafka.network.RequestConvertToJsonTest:
-- testRequestDesc
-- testRequestDescMetrics
-- testRequestHeaderNode
-- testRequestHeaderNodeWithDeprecatedApiVersion
-kafka.network.SocketServerTest:
-- closingChannelSendFailure
-- closingChannelWithBufferedReceivesFailedSend
-- closingChannelWithCompleteAndIncompleteBufferedReceives
-- configureNewConnectionException
-- controlThrowable
-- idleExpiryWithBufferedReceives
-- pollException
-- processCompletedReceiveException
-- processCompletedSendException
-- processDisconnectedException
-- processNewResponseException
-- remoteCloseSendFailure
-- remoteCloseWithBufferedReceives
-- remoteCloseWithBufferedReceivesFailedSend
-- remoteCloseWithCompleteAndIncompleteBufferedReceives
-- remoteCloseWithIncompleteBufferedReceive
-- sendCancelledKeyException
-- simpleRequest
-- testAcceptorStartOpensPortIfNeeded
-- testAuthorizerFailureCausesEnableRequestProcessingFailure
-- testBrokerSendAfterChannelClosedUpdatesRequestMetrics
-- testClientDisconnectionUpdatesRequestMetrics
-- testClientDisconnectionWithOutstandingReceivesProcessedUntilFailedSend
-- testClientInformationWithLatestApiVersionsRequest
-- testClientInformationWithOldestApiVersionsRequest
-- testConnectionDisconnectListenerInvokedOnClose
-- testConnectionId
-- testConnectionIdReuse
-- testConnectionRateLimit
-- testConnectionRatePerIp
-- testControlPlaneAsPrivilegedListener
-- testControlPlaneTakePrecedenceOverInterBrokerListenerAsPrivilegedListener
-- testDisabledRequestIsRejected
-- testExceptionInAcceptor
-- testFailedAcceptorStartupCausesEnableRequestProcessingFailure
-- testGracefulClose
-- testIdleConnection
-- testInterBrokerListenerAsPrivilegedListener
-- testLatencyWithBufferedDataAndNoSocketData
-- testListenBacklogSize
-- testMaxConnectionsPerIp
-- testMaxConnectionsPerIpOverrides
-- testMetricCollectionAfterShutdown
-- testNoOpAction
-- testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone
-- testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress
-- testProcessorMetricsTags
-- testRequestMetricsAfterStop
-- testRequestPerSecAndDeprecatedRequestsPerSecMetrics
-- testSaslReauthenticationFailureNoKip152SaslAuthenticate
-- testSaslReauthenticationFailureWithKip152SaslAuthenticate
-- testSendActionResponseWithThrottledChannelWhereThrottlingAlreadyDone
-- testSendActionResponseWithThrottledChannelWhereThrottlingInProgress
-- testServerShutdownWithoutEnable
-- testSessionPrincipal
-- testSocketsCloseOnShutdown
-- testSslSocketServer
-- testStagedListenerShutdownWhenConnectionQueueIsFull
-- testStagedListenerStartup
-- testThrottledSocketsClosedOnShutdown
-- testUnmuteChannelWithBufferedReceives
-- testZeroMaxConnectionsPerIp
-- tooBigRequestIsRejected
-kafka.raft.KafkaMetadataLogTest:
-- testAdvanceLogStartOffsetAfterCleaning
-- testCleanupOlderSnapshots
-- testCleanupPartialSnapshots
-- testConfig
-- testCreateExistingSnapshot
-- testCreateReplicatedLogTruncatesFully
-- testCreateSnapshot
-- testCreateSnapshotBeforeLogStartOffset
-- testCreateSnapshotDivergingEpoch
-- testCreateSnapshotFromEndOffset
-- testCreateSnapshotInMiddleOfBatch
-- testCreateSnapshotLaterThanHighWatermark
-- testCreateSnapshotMuchLaterEpoch
-- testCreateSnapshotOlderEpoch
-- testCreateSnapshotWithMissingEpoch
-- testDeleteNonExistentSnapshot
-- testDeleteSnapshots
-- testDoesntTruncateFully
-- testHighWatermarkOffsetMetadata
-- testMaxBatchSize
-- testReadMissingSnapshot
-- testSegmentsLessThanLatestSnapshot
-- testSnapshotDeletionWithInvalidSnapshotState
-- testSoftRetentionLimit
-- testStartupWithInvalidSnapshotState
-- testTopicId
-- testTruncateBelowHighWatermark
-- testTruncateFullyToLatestSnapshot
-- testTruncateWillRemoveOlderSnapshot
-- testUnexpectedAppendOffset
-- testValidateEpochGreaterThanLastKnownEpoch
-- testValidateEpochLessThanFirstEpochInLog
-- testValidateEpochLessThanOldestSnapshotEpoch
-- testValidateOffsetEqualToOldestSnapshotOffset
-- testValidateOffsetGreatThanEndOffset
-- testValidateOffsetLessThanLEO
-- testValidateOffsetLessThanOldestSnapshotOffset
-- testValidateUnknownEpochLessThanLastKnownGreaterThanOldestSnapshot
-- testValidateValidEpochAndOffset
-kafka.raft.RaftManagerTest:
-- testKRaftBrokerDoesNotDeleteMetadataLog
-- testLogDirLockWhenBrokerOnlyWithSeparateMetadataDir
-- testLogDirLockWhenControllerOnly
-- testNodeIdPresent
-kafka.security.authorizer.AclEntryTest:
-- testAclJsonConversion
-kafka.security.authorizer.AuthorizerTest:
-- testAccessAllowedIfAllowAclExistsOnPrefixedResource
-- testAccessAllowedIfAllowAclExistsOnWildcardResource
-- testAclConfigWithWhitespace
-- testAclInheritance
-- testAclManagementAPIs
-- testAclsFilter
-- testAddAclsOnLiteralResource
-- testAddAclsOnPrefixedResource
-- testAddAclsOnWildcardResource
-- testAllowAccessWithCustomPrincipal
-- testAllowAllAccess
-- testAuthorizeByResourceTypeDenyTakesPrecedence
-- testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow
-- testAuthorizeByResourceTypeMultipleAddAndRemove
-- testAuthorizeByResourceTypeNoAclFoundOverride
-- testAuthorizeByResourceTypePrefixedResourceDenyDominate
-- testAuthorizeByResourceTypeSuperUserHasAccess
-- testAuthorizeByResourceTypeWildcardResourceDenyDominate
-- testAuthorizeByResourceTypeWithAllHostAce
-- testAuthorizeByResourceTypeWithAllOperationAce
-- testAuthorizeByResourceTypeWithAllPrincipalAce
-- testAuthorizeThrowsOnNonLiteralResource
-- testAuthorizeWithEmptyResourceName
-- testAuthorizeWithPrefixedResource
-- testDeleteAclOnPrefixedResource
-- testDeleteAclOnWildcardResource
-- testDeleteAllAclOnPrefixedResource
-- testDeleteAllAclOnWildcardResource
-- testDenyTakesPrecedence
-- testEmptyAclThrowsException
-- testGetAclsPrincipal
-- testLocalConcurrentModificationOfResourceAcls
-- testNoAclFound
-- testNoAclFoundOverride
-- testSingleCharacterResourceAcls
-- testSuperUserHasAccess
-- testSuperUserWithCustomPrincipalHasAccess
-- testTopicAcl
-- testWildCardAcls
-kafka.security.minikdc.MiniKdcTest:
-- shouldNotStopImmediatelyWhenStarted
-kafka.server.AbstractFetcherManagerTest:
-- testAddAndRemovePartition
-- testDeadThreadCountMetric
-- testExpandThreadPool
-- testMaybeUpdateTopicIds
-- testMetricFailedPartitionCount
-- testShrinkThreadPool
-kafka.server.AbstractFetcherThreadTest:
-- testConsumerLagRemovedWithPartition
-- testCorruptMessage
-- testDelay
-- testDivergingEpochs
-- testFencedFetch
-- testFencedOffsetResetAfterOutOfRange
-- testFencedTruncation
-- testFetcherThreadHandlingPartitionFailureDuringAppending
-- testFetcherThreadHandlingPartitionFailureDuringTruncation
-- testFollowerFetchOutOfRangeHigh
-- testFollowerFetchOutOfRangeLow
-- testLeaderEpochChangeDuringFencedFetchEpochsFromLeader
-- testLeaderEpochChangeDuringSuccessfulFetchEpochsFromLeader
-- testMaybeUpdateTopicIds
-- testMetricsRemovedOnShutdown
-- testPartitionsInError
-- testRetryAfterUnknownLeaderEpochInLatestOffsetFetch
-- testSimpleFetch
-- testTruncateOnFetchDoesNotProcessPartitionData
-- testTruncateToEpochEndOffsetsDuringRemovePartitions
-- testTruncateToHighWatermarkDuringRemovePartitions
-- testTruncateToHighWatermarkIfLeaderEpochInfoNotAvailable
-- testTruncateToHighWatermarkIfLeaderEpochRequestNotSupported
-- testTruncation
-- testTruncationOnFetchSkippedIfPartitionRemoved
-- testTruncationSkippedIfNoEpochChange
-- testTruncationThrowsExceptionIfLeaderReturnsPartitionsNotRequestedInFetchEpochs
-- testUnknownLeaderEpochInTruncation
-- testUnknownLeaderEpochWhileFetching
-kafka.server.AbstractFetcherThreadWithIbp26Test:
-- testConsumerLagRemovedWithPartition
-- testCorruptMessage
-- testDelay
-- testDivergingEpochs
-- testFencedFetch
-- testFencedOffsetResetAfterOutOfRange
-- testFencedTruncation
-- testFetcherThreadHandlingPartitionFailureDuringAppending
-- testFetcherThreadHandlingPartitionFailureDuringTruncation
-- testFollowerFetchOutOfRangeHigh
-- testFollowerFetchOutOfRangeLow
-- testLeaderEpochChangeDuringFencedFetchEpochsFromLeader
-- testLeaderEpochChangeDuringSuccessfulFetchEpochsFromLeader
-- testMaybeUpdateTopicIds
-- testMetricsRemovedOnShutdown
-- testPartitionsInError
-- testRetryAfterUnknownLeaderEpochInLatestOffsetFetch
-- testSimpleFetch
-- testTruncateToEpochEndOffsetsDuringRemovePartitions
-- testTruncateToHighWatermarkDuringRemovePartitions
-- testTruncateToHighWatermarkIfLeaderEpochInfoNotAvailable
-- testTruncateToHighWatermarkIfLeaderEpochRequestNotSupported
-- testTruncation
-- testTruncationSkippedIfNoEpochChange
-- testTruncationThrowsExceptionIfLeaderReturnsPartitionsNotRequestedInFetchEpochs
-- testUnknownLeaderEpochInTruncation
-- testUnknownLeaderEpochWhileFetching
-kafka.server.AddPartitionsToTxnManagerTest:
-- testAddPartitionsToTxnHandlerErrorHandling
-- testAddPartitionsToTxnManagerMetrics
-- testAddTxnData
-- testGenerateRequests
-- testTransactionCoordinatorResolution
-kafka.server.AddPartitionsToTxnRequestServerTest:
-- shouldReceiveOperationNotAttemptedWhenOtherPartitionHasError
-- testOneSuccessOneErrorInBatchedRequest
-- testVerifyOnly
-kafka.server.AlterPartitionManagerTest:
-- testAuthorizationFailed
-- testBasic
-- testBasicSentLeaderRecoveryState
-- testBasicWithBrokerEpoch
-- testInvalidRequest
-- testInvalidUpdateVersion
-- testNotLeaderOrFollower
-- testOneInFlight
-- testOverwriteWithinBatch
-- testPartialTopicIds
-- testPartitionMissingInResponse
-- testRetryOnAuthenticationFailure
-- testRetryOnUnsupportedVersionError
-- testSingleBatch
-- testStaleBrokerEpoch
-- testSubmitFromCallback
-- testUnknownServer
-- testUnknownTopicPartition
-- testZkBasic
-kafka.server.AlterReplicaLogDirsRequestTest:
-- testAlterReplicaLogDirsRequest
-- testAlterReplicaLogDirsRequestErrorCode
-- testAlterReplicaLogDirsRequestWithRetention
-kafka.server.AlterUserScramCredentialsRequestNotAuthorizedTest:
-- testAlterNothingNotAuthorized
-- testAlterSomethingNotAuthorized
-kafka.server.AlterUserScramCredentialsRequestTest:
-- testAlterAndDescribe
-- testAlterEmptyUser
-- testAlterNothing
-- testAlterSameThingTwice
-- testAlterTooFewIterations
-- testAlterTooManyIterations
-- testAlterUnknownMechanism
-- testDeleteSomethingThatDoesNotExist
-- testMetadataVersionTooLow
-kafka.server.ApiVersionManagerTest:
-- testApiScope
-- testControllerApiIntersection
-- testDisabledApis
-- testEnvelopeDisabledForKRaftBroker
-- testEnvelopeDisabledWhenForwardingManagerEmpty
-kafka.server.ApiVersionsRequestTest:
-- testApiVersionsRequest
-- testApiVersionsRequestIncludesUnreleasedApis
-- testApiVersionsRequestThroughControllerListener
-- testApiVersionsRequestValidationV0
-- testApiVersionsRequestValidationV0ThroughControllerListener
-- testApiVersionsRequestValidationV3
-- testApiVersionsRequestWithUnsupportedVersion
-kafka.server.ApiVersionsResponseIntegrationTest:
-- testSendV3ApiVersionsRequest
-- testSendV4ApiVersionsRequest
-kafka.server.AuthHelperTest:
-- testAuthorize
-- testComputeDescribeClusterResponseSuccess
-- testComputeDescribeClusterResponseV0WithUnexpectedEndpointType
-- testComputeDescribeClusterResponseV0WithUnknownEndpointType
-- testComputeDescribeClusterResponseV1WithUnexpectedEndpointType
-- testComputeDescribeClusterResponseV1WithUnknownEndpointType
-- testComputeDescribeClusterResponseWhereControllerIsNotFound
-- testFilterByAuthorized
-kafka.server.AutoTopicCreationManagerTest:
-- testCreateNonInternalTopic
-- testCreateOffsetTopic
-- testCreateShareStateTopic
-- testCreateTopicsWithForwardingDisabled
-- testCreateTxnTopic
-- testInvalidReplicationFactorForConsumerOffsetsTopic
-- testInvalidReplicationFactorForNonInternalTopics
-- testInvalidReplicationFactorForTxnOffsetTopic
-- testRequestTimeoutErrorSwapForConsumerOffsetTopic
-- testRequestTimeoutErrorSwapForNonInternalTopics
-- testRequestTimeoutErrorSwapForTxnOffsetTopic
-- testTopicCreationWithMetadataContextNoRetryUponUnsupportedVersion
-- testTopicCreationWithMetadataContextPassPrincipal
-- testTopicCreationWithMetadataContextWhenPrincipalSerdeNotDefined
-- testTopicExistsErrorSwapForConsumerOffsetsTopic
-- testTopicExistsErrorSwapForNonInternalTopics
-- testTopicExistsErrorSwapForTxnOffsetTopic
-- testUnknownTopicPartitionForConsumerOffsetTopic
-- testUnknownTopicPartitionForNonIntervalTopic
-- testUnknownTopicPartitionForTxnOffsetTopic
-kafka.server.BootstrapControllersIntegrationTest:
-- testAcls
-- testAclsByControllers
-- testAlterReassignmentsWithBootstrapControllers
-- testDescribeCluster
-- testDescribeClusterByControllers
-- testDescribeFeatures
-- testDescribeFeaturesByControllers
-- testDescribeMetadataQuorum
-- testDescribeMetadataQuorumByControllers
-- testIncrementalAlterConfigs
-- testIncrementalAlterConfigsByControllers
-- testPutBrokersInBootstrapControllersConfig
-- testPutControllersInBootstrapBrokersConfig
-- testUpdateFeatures
-- testUpdateFeaturesByControllers
-- testUsingBootstrapControllersOnUnsupportedAdminApi
-kafka.server.BrokerLifecycleManagerTest:
-- testAlwaysSendsAccumulatedOfflineDirs
-- testControlledShutdown
-- testCreateAndClose
-- testCreateStartAndClose
-- testKraftJBODMetadataVersionUpdateEvent
-- testRegistrationIncludesDirs
-- testRegistrationTimeout
-- testSuccessfulRegistration
-kafka.server.BrokerMetricNamesTest:
-- testMetrics
-kafka.server.BrokerRegistrationRequestTest:
-- testRegisterZkWith33Controller
-kafka.server.ClientQuotaManagerTest:
-- testClientIdNotSanitized
-- testClientIdQuotaParsing
-- testExpireQuotaSensors
-- testExpireThrottleTimeSensor
-- testGetMaxValueInQuotaWindowWithNonDefaultQuotaWindow
-- testQuotaConfigPrecedence
-- testQuotaViolation
-- testSetAndRemoveDefaultUserQuota
-- testSetAndRemoveUserClientQuota
-- testSetAndRemoveUserQuota
-- testUserClientIdQuotaParsing
-- testUserClientQuotaParsingIdWithDefaultClientIdQuota
-- testUserQuotaParsing
-- testUserQuotaParsingWithDefaultClientIdQuota
-kafka.server.ClientQuotasRequestTest:
-- testAlterClientQuotasBadIp
-- testAlterClientQuotasInvalidEntityCombination
-- testAlterClientQuotasInvalidRequests
-- testAlterClientQuotasRequest
-- testAlterClientQuotasRequestValidateOnly
-- testAlterIpQuotasRequest
-- testClientQuotasSanitized
-- testClientQuotasUnsupportedEntityTypes
-- testClientQuotasWithDefaultName
-- testDescribeClientQuotasInvalidFilterCombination
-- testDescribeClientQuotasMatchExact
-- testDescribeClientQuotasMatchPartial
-kafka.server.ClientRequestQuotaManagerTest:
-- testRequestPercentageQuotaViolation
-kafka.server.ConfigAdminManagerTest:
-- testContainsDuplicates
-- testCopyWithoutPreprocessedForIncremental
-- testCopyWithoutPreprocessedForLegacy
-- testPreprocessIncrementalWithDuplicates
-- testPreprocessIncrementalWithLoggerChanges
-- testPreprocessIncrementalWithNulls
-- testPreprocessIncrementalWithUnauthorizedBrokerLoggerChanges
-- testPreprocessIncrementalWithUnknownResource
-- testPreprocessLegacyWithBrokerLoggerChanges
-- testPreprocessLegacyWithDuplicates
-- testPreprocessLegacyWithNulls
-- testPreprocessLegacyWithUnknownResource
-- testReassembleIncrementalResponse
-- testReassembleLegacyResponse
-- testValidateResourceNameIsCurrentNodeId
kafka.server.ConsumerGroupDescribeRequestTest:
-- testConsumerGroupDescribeWhenFeatureFlagNotEnabled
- testConsumerGroupDescribeWithMigrationMember
-- testConsumerGroupDescribeWithNewGroupCoordinator
kafka.server.ConsumerGroupHeartbeatRequestTest:
-- testConsumerGroupHeartbeatFailureIfMemberIdMissingForVersionsAbove0
-- testConsumerGroupHeartbeatIsAccessibleWhenNewGroupCoordinatorIsEnabled
-- testConsumerGroupHeartbeatIsInaccessibleWhenDisabledByStaticConfig
-- testConsumerGroupHeartbeatIsInaccessibleWhenFeatureFlagNotEnabled
- testConsumerGroupHeartbeatWithEmptySubscription
-- testConsumerGroupHeartbeatWithInvalidRegularExpression
-- testConsumerGroupHeartbeatWithRegularExpression
-- testMemberIdGeneratedOnServerWhenApiVersionIs0
-- testRejoiningStaticMemberGetsAssignmentsBackWhenNewGroupCoordinatorIsEnabled
-- testStaticMemberRemovedAfterSessionTimeoutExpiryWhenNewGroupCoordinatorIsEnabled
-- testUpdateConsumerGroupHeartbeatConfigSuccessful
-kafka.server.ConsumerProtocolMigrationTest:
-- testDowngradeFromEmptyConsumerToClassicGroupWithBidirectionalPolicy
-- testDowngradeFromEmptyConsumerToClassicGroupWithDisabledPolicy
-- testDowngradeFromEmptyConsumerToClassicGroupWithDowngradePolicy
-- testDowngradeFromEmptyConsumerToClassicGroupWithUpgradePolicy
-- testDowngradeMigrationPolicy
-- testDowngradeWithDisabledMigrationPolicy
-- testOnlineMigrationWithCooperativeAssignmentStrategyAndDynamicMembers
-- testOnlineMigrationWithCooperativeAssignmentStrategyAndStaticMembers
-- testOnlineMigrationWithEagerAssignmentStrategyAndDynamicMembers
-- testOnlineMigrationWithEagerAssignmentStrategyAndStaticMembers
-- testOnlineMigrationWithNonEmptyUserDataInAssignment
-- testUpgradeFromEmptyClassicToConsumerGroupWithBidirectionalPolicy
-- testUpgradeFromEmptyClassicToConsumerGroupWithDisabledPolicy
-- testUpgradeFromEmptyClassicToConsumerGroupWithDowngradePolicy
-- testUpgradeFromEmptyClassicToConsumerGroupWithUpgradePolicy
-- testUpgradeFromSimpleGroupToConsumerGroupWithBidirectionalPolicy
-- testUpgradeFromSimpleGroupToConsumerGroupWithDisabledPolicy
-- testUpgradeFromSimpleGroupToConsumerGroupWithDowngradePolicy
-- testUpgradeFromSimpleGroupToConsumerGroupWithUpgradePolicy
-- testUpgradeMigrationPolicy
-- testUpgradeWithDisabledMigrationPolicy
-kafka.server.ControllerApisTest:
-- testAllocateProducerIdsReturnsNotController
-- testAssignReplicasToDirs
-- testClose
-- testCompletableFutureExceptions
-- testCreatePartitionsAuthorization
-- testCreatePartitionsMutationQuota
-- testCreatePartitionsRequest
-- testCreateTopics
-- testCreateTopicsMutationQuota
-- testDeleteTopicsById
-- testDeleteTopicsByName
-- testDeleteTopicsDisabled
-- testDeleteTopicsMutationQuota
-- testDeleteTopicsReturnsNotController
-- testElectLeadersAuthorization
-- testElectLeadersHandledByController
-- testFetchLocalTimeComputedCorrectly
-- testFetchSentToKRaft
-- testFetchSnapshotSentToKRaft
-- testHandleLegacyAlterConfigsErrors
-- testInvalidDeleteTopicsRequest
-- testInvalidIncrementalAlterConfigsResources
-- testNotAuthorizedToDeleteWithTopicExisting
-- testNotAuthorizedToDeleteWithTopicNotExisting
-- testNotControllerErrorPreventsDeletingTopics
-- testUnauthorizedBeginQuorumEpoch
-- testUnauthorizedBrokerRegistration
-- testUnauthorizedControllerRegistrationRequest
-- testUnauthorizedDescribeClusterRequest
-- testUnauthorizedDescribeQuorum
-- testUnauthorizedEndQuorumEpoch
-- testUnauthorizedFetch
-- testUnauthorizedFetchSnapshot
-- testUnauthorizedHandleAllocateProducerIds
-- testUnauthorizedHandleAlterClientQuotas
-- testUnauthorizedHandleAlterPartitionReassignments
-- testUnauthorizedHandleAlterPartitionRequest
-- testUnauthorizedHandleBrokerHeartBeatRequest
-- testUnauthorizedHandleIncrementalAlterConfigs
-- testUnauthorizedHandleListPartitionReassignments
-- testUnauthorizedHandleUnregisterBroker
-- testUnauthorizedVote
-kafka.server.ControllerConfigurationValidatorTest:
-- testDefaultTopicResourceIsRejected
-- testDisablingRemoteStorageTopicConfig
-- testInvalidBrokerEntity
-- testInvalidGroupConfig
-- testInvalidGroupNameGroupConfig
-- testInvalidIntervalClientMetricsConfig
-- testInvalidMatchClientMetricsConfig
-- testInvalidNegativeBrokerId
-- testInvalidSubscriptionNameClientMetricsConfig
-- testInvalidTopicConfig
-- testInvalidTopicNameRejected
-- testNullGroupConfigValue
-- testNullTopicConfigValue
-- testUndefinedConfigClientMetricsConfig
-- testUnknownResourceType
-- testValidClientMetricsConfig
-- testValidGroupConfig
-- testValidTopicConfig
-kafka.server.ControllerMutationQuotaManagerTest:
-- testControllerMutationQuotaViolation
-- testNewPermissiveQuotaForReturnsStrictQuotaWhenQuotaIsEnabled
-- testNewPermissiveQuotaForReturnsUnboundedQuotaWhenQuotaIsDisabled
-- testNewStrictQuotaForReturnsStrictQuotaWhenQuotaIsEnabled
-- testNewStrictQuotaForReturnsUnboundedQuotaWhenQuotaIsDisabled
-- testThrottleTime
-kafka.server.ControllerMutationQuotaTest:
-- testPermissiveCreatePartitionsRequest
-- testPermissiveCreateTopicsRequest
-- testPermissiveDeleteTopicsRequest
-- testQuotaMetric
-- testSetUnsetQuota
-- testStrictCreatePartitionsRequest
-- testStrictCreateTopicsRequest
-- testStrictDeleteTopicsRequest
-- testUnboundedCreatePartitionsRequest
-- testUnboundedCreateTopicsRequest
-- testUnboundedDeleteTopicsRequest
-kafka.server.ControllerRegistrationManagerTest:
-- testCreateAndClose
-- testCreateStartAndClose
-- testRegistration
-- testRetransmitRegistration
-- testWrongIncarnationId
-kafka.server.CreateTopicsRequestTest:
-- testCreateClusterMetadataTopic
-- testCreateTopicsRequestVersions
-- testErrorCreateTopicsRequests
-- testInvalidCreateTopicsRequests
-- testValidCreateTopicsRequests
-kafka.server.CreateTopicsRequestWithPolicyTest:
-- testErrorCreateTopicsRequests
-- testValidCreateTopicsRequests
-kafka.server.DelayedFetchTest:
-- testDelayedFetchWithMessageOnlyHighWatermark
-- testDivergingEpoch
-- testFetchWithFencedEpoch
-- testNotLeaderOrFollower
-kafka.server.DelayedRemoteFetchTest:
-- testErrorLogReadInfo
-- testFetch
-- testFollowerFetch
-- testNotLeaderOrFollower
-- testRequestExpiry
-kafka.server.DelayedRemoteListOffsetsTest:
-- testPartialResponseWhenNotLeaderOrFollowerExceptionOnOnePartition
-- testResponseOnPartialError
-- testResponseOnRequestExpiration
-- testResponseOnSuccess
-kafka.server.DelegationTokenRequestsOnPlainTextTest:
-- testDelegationTokenRequests
-kafka.server.DelegationTokenRequestsTest:
-- testDelegationTokenRequests
-kafka.server.DelegationTokenRequestsWithDisableTokenFeatureTest:
-- testDelegationTokenRequests
-kafka.server.DeleteGroupsRequestTest:
-- testDeleteGroupsWithNewConsumerGroupProtocolAndNewGroupCoordinator
-- testDeleteGroupsWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testDeleteGroupsWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.DeleteRecordsRequestTest:
-- testDeleteRecordsHappyCase
-- testErrorWhenDeletingRecordsWithInvalidOffset
-- testErrorWhenDeletingRecordsWithInvalidTopic
-kafka.server.DeleteTopicsRequestTest:
-- testDeleteTopicsVersions
-- testTopicDeletionClusterHasOfflinePartitions
-- testValidDeleteTopicRequests
-kafka.server.DeleteTopicsRequestWithDeletionDisabledTest:
-- testDeleteRecordsRequest
-kafka.server.DescribeClusterRequestTest:
-- testDescribeClusterRequestExcludingClusterAuthorizedOperations
-- testDescribeClusterRequestIncludingClusterAuthorizedOperations
-kafka.server.DescribeGroupsRequestTest:
-- testDescribeGroupsWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testDescribeGroupsWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.DescribeLogDirsRequestTest:
-- testDescribeLogDirsRequest
-kafka.server.DescribeQuorumRequestTest:
-- testDescribeQuorum
-kafka.server.DescribeUserScramCredentialsRequestNotAuthorizedTest:
-- testDescribeNotAuthorized
-kafka.server.DescribeUserScramCredentialsRequestTest:
-- testDescribeNotController
-- testDescribeNothing
-- testDescribeSameUserTwice
-- testDescribeWithNull
-- testUnknownUser
-kafka.server.DynamicBrokerConfigTest:
-- testAuthorizerConfig
-- testCombinedControllerAuthorizerConfig
-- testConfigUpdate
-- testConfigUpdateWithReconfigurableValidationFailure
-- testConfigUpdateWithSomeInvalidConfigs
-- testConnectionQuota
-- testConnectionRateQuota
-- testDynamicConfigInitializationWithoutConfigsInZK
-- testDynamicListenerConfig
-- testDynamicLogConfigHandlesSynonymsCorrectly
-- testDynamicLogLocalRetentionMsConfig
-- testDynamicLogLocalRetentionSizeConfig
-- testDynamicLogLocalRetentionSkipsOnInvalidConfig
-- testDynamicLogLocalRetentionThrowsOnIncorrectConfig
-- testDynamicRemoteFetchMaxWaitMsConfig
-- testDynamicRemoteListOffsetsRequestTimeoutMsConfig
-- testEnableDefaultUncleanLeaderElection
-- testImproperConfigsAreRemoved
-- testIsolatedControllerAuthorizerConfig
-- testLogRetentionTimeMinutesIsNotDynamicallyReconfigurable
-- testNonInternalValuesDoesNotExposeInternalConfigs
-- testPasswordConfigEncoderSecretChange
-- testPasswordConfigEncryption
-- testReconfigurableValidation
-- testRemoteLogDynamicThreadPoolWithInvalidValues
-- testRemoteLogManagerCopyQuotaUpdates
-- testRemoteLogManagerFetchQuotaUpdates
-- testRemoteLogManagerMultipleConfigUpdates
-- testSecurityConfigs
-- testSynonyms
-- testUpdateDynamicRemoteLogManagerConfig
-- testUpdateDynamicThreadPool
-- testUpdateMetricReporters
-- testUpdateMetricReportersNoJmxReporter
-- testUpdateRemoteLogManagerDynamicThreadPool
-kafka.server.DynamicBrokerReconfigurationTest:
-- testConfigDescribeUsingAdminClient
-- testConsecutiveConfigChange
-- testDefaultTopicConfig
-- testKeyStoreAlter
-- testLogCleanerConfig
-- testMetricsReporterUpdate
-- testReconfigureRemovedListener
-- testThreadPoolResize
-- testTransactionVerificationEnable
-- testTrustStoreAlter
-- testUncleanLeaderElectionEnable
-- testUpdatesUsingConfigProvider
-kafka.server.DynamicConfigChangeTest:
-- testBrokerIdConfigChangeAndDelete
-- testClientIdQuotaConfigChange
-- testConfigChange
-- testConfigChangeOnNonExistingTopicWithAdminClient
-- testDefaultAndBrokerIdConfigChange
-- testDefaultBrokerIdConfigChangeAndDelete
-- testDefaultClientIdQuotaConfigChange
-- testDefaultUserClientIdQuotaConfigChange
-- testDefaultUserQuotaConfigChange
-- testDynamicGroupConfigChange
-- testDynamicShareGroupConfigChange
-- testDynamicTopicConfigChange
-- testIncrementalAlterDefaultGroupConfig
-- testIncrementalAlterDefaultTopicConfig
-- testIpQuotaConfigChange
-- testIpQuotaInitialization
-- testUserClientIdQuotaChange
-- testUserQuotaConfigChange
-kafka.server.DynamicConfigChangeUnitTest:
-- shouldParseRegardlessOfWhitespaceAroundValues
-- shouldParseReplicationQuotaProperties
-- shouldParseReplicationQuotaReset
-- shouldParseWildcardReplicationQuotaProperties
-- testEnableRemoteLogStorageOnTopic
-- testEnableRemoteLogStorageOnTopicOnAlreadyEnabledTopic
-- testIpHandlerUnresolvableAddress
-kafka.server.EdgeCaseRequestTest:
-- testHeaderOnlyRequest
-- testInvalidApiKeyRequest
-- testInvalidApiVersionRequest
-- testMalformedHeaderRequest
-- testProduceRequestWithNullClientId
-kafka.server.FetchFromFollowerIntegrationTest:
-- testFetchFromFollowerWithRoll
-- testFetchFromLeaderWhilePreferredReadReplicaIsUnavailable
-- testFollowerCompleteDelayedFetchesOnReplication
-kafka.server.FetchRequestDownConversionConfigTest:
-- testLatestFetchWithDownConversionDisabled
-- testV12WithDownConversionDisabled
-- testV1FetchFromConsumer
-- testV1FetchFromReplica
-- testV1FetchWithDownConversionDisabled
-kafka.server.FetchRequestMaxBytesTest:
-- testConsumeMultipleRecords
-kafka.server.FetchRequestTest:
-- testBrokerRespectsPartitionsOrderAndSizeLimits
-- testCreateIncrementalFetchWithPartitionsInErrorV12
-- testCurrentEpochValidation
-- testCurrentEpochValidationV12
-- testDownConversionFromBatchedToUnbatchedRespectsOffset
-- testDownConversionWithConnectionFailure
-- testEpochValidationWithinFetchSession
-- testEpochValidationWithinFetchSessionV12
-- testFetchRequestToNonReplica
-- testFetchRequestV4WithReadCommitted
-- testFetchWithPartitionsWithIdError
-- testLastFetchedEpochValidation
-- testLastFetchedEpochValidationV12
-- testZStdCompressedRecords
-- testZStdCompressedTopic
-kafka.server.FetchSessionTest:
-- testCachedLeaderEpoch
-- testCachedPartitionEqualsAndHashCode
-- testDeprioritizesPartitionsWithRecordsOnly
-- testDivergingEpoch
-- testFetchRequests
-- testFetchSessionCache_RoundRobinsIntoShards
-- testFetchSessionCache_RoundRobinsIntoShards_WhenIntegerOverflows
-- testFetchSessionCache_getShardedCache_retrievesCacheFromCorrectSegment
-- testFetchSessionExpiration
-- testFetchSessionUpdateTopicIdsBrokerSide
-- testFetchSessionWithUnknownId
-- testFetchSessionWithUnknownIdOldRequestVersion
-- testIncrementalFetchSession
-- testIncrementalFetchSessionWithIdsWhenSessionDoesNotUseIds
-- testIncrementalFetchSessionWithoutIdsWhenSessionUsesIds
-- testLastFetchedEpoch
-- testMaybeResolveUnknownName
-- testNewSessionId
-- testPrivilegedSessionHandling
-- testResizeCachedSessions
-- testResolveUnknownPartitions
-- testSessionCache
-- testToForgetPartitions
-- testUpdateAndGenerateResponseData
-- testZeroSizeFetchSession
-kafka.server.FinalizedFeatureCacheTest:
-- testClear
-- testEmpty
-- testUpdateOrThrowFailedDueToInvalidEpoch
-- testUpdateOrThrowFailedDueToInvalidFeatures
-- testUpdateOrThrowSuccess
-kafka.server.ForwardingManagerTest:
-- testFailedAuthentication
-- testForwardingManagerMetricsOnComplete
-- testForwardingManagerMetricsOnTimeout
-- testForwardingTimeoutAfterRetry
-- testForwardingTimeoutWaitingForControllerDiscovery
-- testResponseCorrelationIdMismatch
-- testUnsupportedVersionFromNetworkClient
-- testUnsupportedVersions
-kafka.server.GssapiAuthenticationTest:
-- testLoginFailure
-- testReLogin
-- testRequestIsAReplay
-- testServerAuthenticationFailure
-- testServerNotFoundInKerberosDatabase
-kafka.server.HeartbeatRequestTest:
-- testHeartbeatWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testHeartbeatWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.HighwatermarkPersistenceTest:
-- testHighWatermarkPersistenceMultiplePartitions
-- testHighWatermarkPersistenceSinglePartition
-kafka.server.IsrExpirationTest:
-- testIsrExpirationForCaughtUpFollowers
-- testIsrExpirationForSlowFollowers
-- testIsrExpirationForStuckFollowers
-- testIsrExpirationIfNoFetchRequestMade
-kafka.server.JoinGroupRequestTest:
-- testJoinGroupWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testJoinGroupWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.KRaftClusterTest:
-- testAbandonedFutureReplicaRecovered_mainReplicaInOfflineLogDir
-- testAbandonedFutureReplicaRecovered_mainReplicaInOnlineLogDir
-- testAuthorizerFailureFoundInControllerStartup
-- testClientQuotas
-- testControllerFailover
-- testCreateClusterAndClose
-- testCreateClusterAndCreateAndManyTopics
-- testCreateClusterAndCreateListDeleteTopic
-- testCreateClusterAndCreateTopicWithRemoteLogManagerInstantiation
-- testCreateClusterAndPerformReassignment
-- testCreateClusterAndRestartBrokerNode
-- testCreateClusterAndRestartControllerNode
-- testCreateClusterAndWaitForBrokerInRunningState
-- testCreateClusterInvalidMetadataVersion
-- testCreateClusterWithAdvertisedHostAndPortDifferentFromSocketServer
-- testCreateClusterWithAdvertisedPortZero
-- testCreatePartitions
-- testDefaultClientQuotas
-- testDescribeQuorumRequestToBrokers
-- testDirectToControllerCommunicationFailsOnOlderMetadataVersion
-- testIncreaseNumIoThreads
-- testIncrementalAlterConfigs
-- testOverlyLargeCreateTopics
-- testReconfigureControllerAuthorizer
-- testReconfigureControllerClientQuotas
-- testRegisteredControllerEndpoints
-- testRemoteLogManagerInstantiation
-- testSetLog4jConfigurations
-- testSingleControllerSingleBrokerCluster
-- testSnapshotCount
-- testStartupWithNonDefaultKControllerDynamicConfiguration
-- testTimedOutHeartbeats
-- testTopicDeletedAndRecreatedWhileBrokerIsDown
-- testUnregisterBroker
-- testUpdateMetadataVersion
-kafka.server.KafkaApisTest:
-- rejectHeartbeatRequestWhenStaticMembershipNotSupported
-- rejectInitProducerIdWhenEpochButNotIdProvided
-- rejectInitProducerIdWhenIdButNotEpochProvided
-- rejectJoinGroupRequestWhenStaticMembershipNotSupported
-- rejectOffsetCommitRequestWhenStaticMembershipNotSupported
-- rejectSyncGroupRequestWhenStaticMembershipNotSupported
-- requiredAclsNotPresentWriteTxnMarkersThrowsAuthorizationException
-- shouldAppendToLogOnWriteTxnMarkersWhenCorrectMagicVersion
-- shouldNotResignCoordinatorsIfStopReplicaReceivedWithoutDeleteFlag
-- shouldReplaceCoordinatorNotAvailableWithLoadInProcessInTxnOffsetCommitWithOlderClient
-- shouldReplaceProducerFencedWithInvalidProducerEpochInAddOffsetToTxnWithOlderClient
-- shouldReplaceProducerFencedWithInvalidProducerEpochInAddPartitionToTxnWithOlderClient
-- shouldReplaceProducerFencedWithInvalidProducerEpochInEndTxnWithOlderClient
-- shouldReplaceProducerFencedWithInvalidProducerEpochInInitProducerIdWithOlderClient
-- shouldReplaceProducerFencedWithInvalidProducerEpochInProduceResponse
-- shouldResignCoordinatorsIfStopReplicaReceivedWithDeleteFlagAndDeleteSentinel
-- shouldResignCoordinatorsIfStopReplicaReceivedWithDeleteFlagAndLeaderEpoch
-- shouldResignCoordinatorsIfStopReplicaReceivedWithDeleteFlagAndNoEpochSentinel
-- shouldRespondWithUnknownTopicOrPartitionForBadPartitionAndNoErrorsForGoodPartition
-- shouldRespondWithUnknownTopicWhenPartitionIsNotHosted
-- shouldRespondWithUnsupportedForMessageFormatOnHandleWriteTxnMarkersWhenMagicLowerThanRequired
-- shouldRespondWithUnsupportedMessageFormatForBadPartitionAndNoErrorsForGoodPartition
-- shouldThrowUnsupportedVersionExceptionOnHandleAddOffsetToTxnRequestWhenInterBrokerProtocolNotSupported
-- shouldThrowUnsupportedVersionExceptionOnHandleAddPartitionsToTxnRequestWhenInterBrokerProtocolNotSupported
-- shouldThrowUnsupportedVersionExceptionOnHandleEndTxnRequestWhenInterBrokerProtocolNotSupported
-- shouldThrowUnsupportedVersionExceptionOnHandleTxnOffsetCommitRequestWhenInterBrokerProtocolNotSupported
-- shouldThrowUnsupportedVersionExceptionOnHandleWriteTxnMarkersRequestWhenInterBrokerProtocolNotSupported
-- testAddPartitionsToTxnOperationNotAttempted
-- testAddPartitionsToTxnWithInvalidPartition
-- testAlterClientQuotasWithAuthorizer
-- testAlterClientQuotasWithForwarding
-- testAlterConfigsClientMetrics
-- testAlterConfigsWithAuthorizer
-- testAlterPartitionReassignmentsWithForwarding
-- testAlterReplicaLogDirs
-- testAlterScramWithForwarding
-- testBatchedAddPartitionsToTxnRequest
-- testConsumerGroupDescribe
-- testConsumerGroupDescribeAuthorizationFailed
-- testConsumerGroupDescribeFutureFailed
-- testConsumerGroupDescribeReturnsUnsupportedVersion
-- testConsumerGroupHeartbeatRequest
-- testConsumerGroupHeartbeatRequestAuthorizationFailed
-- testConsumerGroupHeartbeatRequestFutureFailed
-- testConsumerGroupHeartbeatReturnsUnsupportedVersion
-- testCreateAclWithForwarding
-- testCreateDelegationTokenWithForwarding
-- testCreatePartitionsAuthorization
-- testCreatePartitionsWithForwarding
-- testCreateTopicsWithAuthorizer
-- testCreateTopicsWithForwarding
-- testDeleteAclWithForwarding
-- testDeleteTopicsByIdAuthorization
-- testDeleteTopicsByNameAuthorization
-- testDeleteTopicsWithForwarding
-- testDescribeClusterRequest
-- testDescribeConfigsClientMetrics
-- testDescribeConfigsConsumerGroup
-- testDescribeConfigsWithAuthorizer
-- testDescribeProducers
-- testDescribeQuorumForwardedForKRaftClusters
-- testDescribeQuorumNotAllowedForZkClusters
-- testDescribeTransactions
-- testDescribeTransactionsFiltersUnauthorizedTopics
-- testElectLeadersForwarding
-- testEmptyIncrementalAlterConfigsRequestWithKRaft
-- testEmptyLegacyAlterConfigsRequestWithKRaft
-- testEnvelopeRequestHandlingAsController
-- testEnvelopeRequestNotAuthorized
-- testEnvelopeRequestNotControllerHandling
-- testEnvelopeRequestWithAlterConfigUnhandledError
-- testEnvelopeRequestWithNotFromPrivilegedListener
-- testExpireDelegationTokenWithForwarding
-- testFetchRequestErroneousPartitions
-- testFetchRequestV9WithNoLogConfig
-- testFetchResponseContainsNewLeaderOnNotLeaderOrFollower
-- testFindCoordinatorAutoTopicCreationForOffsetTopic
-- testFindCoordinatorAutoTopicCreationForTxnTopic
-- testFindCoordinatorNoShareCoordinatorForShareStateTopic
-- testFindCoordinatorNotEnoughBrokersForOffsetTopic
-- testFindCoordinatorNotEnoughBrokersForTxnTopic
-- testFindCoordinatorTooOldForShareStateTopic
-- testGetAcknowledgeBatchesFromShareAcknowledgeRequest
-- testGetAcknowledgeBatchesFromShareAcknowledgeRequestError
-- testGetAcknowledgeBatchesFromShareFetchRequest
-- testGetAcknowledgeBatchesFromShareFetchRequestError
-- testGetAllTopicMetadataShouldNotCreateTopicOrReturnUnknownTopicPartition
-- testGetTelemetrySubscriptions
-- testGetTelemetrySubscriptionsNotAllowedForZkClusters
-- testGetTelemetrySubscriptionsWithException
-- testHandleAcknowledgementsInvalidAcknowledgementBatches
-- testHandleAcknowledgementsSuccess
-- testHandleAcknowledgementsUnauthorizedTopics
-- testHandleAcknowledgementsWithErroneous
-- testHandleAddPartitionsToTxnAuthorizationFailedAndMetrics
-- testHandleDeleteGroups
-- testHandleDeleteGroupsAuthenticationFailed
-- testHandleDeleteGroupsFutureFailed
-- testHandleDescribeGroups
-- testHandleDescribeGroupsAuthenticationFailed
-- testHandleDescribeGroupsFutureFailed
-- testHandleFetchFromShareFetchRequestSuccess
-- testHandleHeartbeatRequest
-- testHandleHeartbeatRequestAuthenticationFailed
-- testHandleHeartbeatRequestFutureFailed
-- testHandleJoinGroupRequest
-- testHandleJoinGroupRequestAuthorizationFailed
-- testHandleJoinGroupRequestFutureFailed
-- testHandleJoinGroupRequestUnexpectedException
-- testHandleLeaveGroupAuthenticationFailed
-- testHandleLeaveGroupFutureFailed
-- testHandleLeaveGroupWithMultipleMembers
-- testHandleLeaveGroupWithSingleMember
-- testHandleOffsetCommitRequest
-- testHandleOffsetCommitRequestFutureFailed
-- testHandleOffsetCommitRequestTopicsAndPartitionsValidation
-- testHandleOffsetFetchAllOffsetsWithSingleGroup
-- testHandleOffsetFetchAuthorization
-- testHandleOffsetFetchWithMultipleGroups
-- testHandleOffsetFetchWithSingleGroup
-- testHandleOffsetFetchWithUnauthorizedTopicAndTopLevelError
-- testHandleShareAcknowledgeNewGroupCoordinatorDisabled
-- testHandleShareAcknowledgeRequestAcknowledgeThrowsError
-- testHandleShareAcknowledgeRequestBatchValidationError
-- testHandleShareAcknowledgeRequestGroupAuthorizationError
-- testHandleShareAcknowledgeRequestInvalidRequestOnInitialEpoch
-- testHandleShareAcknowledgeRequestReleaseAcquiredRecordsThrowError
-- testHandleShareAcknowledgeRequestSessionNotFound
-- testHandleShareAcknowledgeRequestSuccess
-- testHandleShareAcknowledgeRequestSuccessOnFinalEpoch
-- testHandleShareAcknowledgeResponseContainsNewLeaderOnNotLeaderOrFollower
-- testHandleShareAcknowledgeShareGroupDisabled
-- testHandleShareFetchFetchMessagesReturnErrorCode
-- testHandleShareFetchFromShareFetchRequestErrorTopicsInRequest
-- testHandleShareFetchFromShareFetchRequestWithErroneousPartitions
-- testHandleShareFetchNewGroupCoordinatorDisabled
-- testHandleShareFetchRequestAcknowledgeThrowsException
-- testHandleShareFetchRequestErrorInReadingPartition
-- testHandleShareFetchRequestFetchAndAcknowledgeThrowsException
-- testHandleShareFetchRequestFetchThrowsException
-- testHandleShareFetchRequestGroupAuthorizationError
-- testHandleShareFetchRequestInvalidRequestOnFinalEpoch
-- testHandleShareFetchRequestInvalidRequestOnInitialEpoch
-- testHandleShareFetchRequestInvalidShareSessionError
-- testHandleShareFetchRequestReleaseAcquiredRecordsThrowError
-- testHandleShareFetchRequestShareSessionNotFoundError
-- testHandleShareFetchRequestShareSessionSuccessfullyEstablished
-- testHandleShareFetchRequestSuccessWithAcknowledgements
-- testHandleShareFetchRequestSuccessWithoutAcknowledgements
-- testHandleShareFetchRequestSuccessfulShareSessionLifecycle
-- testHandleShareFetchShareGroupDisabled
-- testHandleSyncGroupRequest
-- testHandleSyncGroupRequestAuthenticationFailed
-- testHandleSyncGroupRequestFutureFailed
-- testHandleTxnOffsetCommitRequest
-- testHandleTxnOffsetCommitRequestFutureFailed
-- testHandleTxnOffsetCommitRequestTopicsAndPartitionsValidation
-- testHandleWriteTxnMarkersRequestWithNewGroupCoordinator
-- testHandleWriteTxnMarkersRequestWithNewGroupCoordinatorErrorTranslation
-- testHandleWriteTxnMarkersRequestWithOldGroupCoordinator
-- testIncrementalAlterConfigsWithAuthorizer
-- testIncrementalClientMetricAlterConfigs
-- testIncrementalConsumerGroupAlterConfigs
-- testInvalidEnvelopeRequestWithNonForwardableAPI
-- testInvalidLegacyAlterConfigsRequestWithKRaft
-- testInvalidMetadataRequestReturnsError
-- testJoinGroupProtocolNameBackwardCompatibility
-- testKRaftControllerThrottleTimeEnforced
-- testLeaderAndIsrRequestWithCurrentBrokerEpoch
-- testLeaderAndIsrRequestWithNewerBrokerEpochIsValid
-- testLeaderAndIsrRequestWithStaleBrokerEpochIsRejected
-- testLeaderReplicaIfLocalRaisesFencedLeaderEpoch
-- testLeaderReplicaIfLocalRaisesNotLeaderOrFollower
-- testLeaderReplicaIfLocalRaisesUnknownLeaderEpoch
-- testLeaderReplicaIfLocalRaisesUnknownTopicOrPartition
-- testListClientMetricsResources
-- testListClientMetricsResourcesEmptyResponse
-- testListClientMetricsResourcesNotAllowedForZkClusters
-- testListClientMetricsResourcesWithException
-- testListGroupsRequest
-- testListGroupsRequestFiltersUnauthorizedGroupsWithDescribeCluster
-- testListGroupsRequestFiltersUnauthorizedGroupsWithDescribeGroups
-- testListGroupsRequestFutureFailed
-- testListOffsetEarliestLocalTimestampWithUnsupportedVersion
-- testListOffsetLatestTieredTimestampWithUnsupportedVersion
-- testListOffsetMaxTimestampWithUnsupportedVersion
-- testListOffsetNegativeTimestampWithOneOrAboveVersion
-- testListOffsetNegativeTimestampWithZeroVersion
-- testListTransactionsAuthorization
-- testListTransactionsErrorResponse
-- testLog4jIncrementalAlterConfigsRequestWithKRaft
-- testMetadataAutoCreationDisabledForNonInternal
-- testMetadataAutoTopicCreationDisabledForNonInternalTopic
-- testMetadataAutoTopicCreationDisabledForOffsetTopic
-- testMetadataAutoTopicCreationDisabledForTxnTopic
-- testMetadataAutoTopicCreationForNonInternalTopic
-- testMetadataAutoTopicCreationForOffsetTopic
-- testMetadataAutoTopicCreationForTxnTopic
-- testMetadataRequestOnDistinctListenerWithInconsistentListenersAcrossBrokers
-- testMetadataRequestOnSharedListenerWithInconsistentListenersAcrossBrokers
-- testOffsetCommitWithInvalidPartition
-- testOffsetDelete
-- testOffsetDeleteTopicsAndPartitionsValidation
-- testOffsetDeleteWithInvalidGroup
-- testOffsetDeleteWithInvalidGroupWithTopLevelError
-- testOffsetDeleteWithInvalidPartition
-- testOldFindCoordinatorAutoTopicCreationForOffsetTopic
-- testOldFindCoordinatorAutoTopicCreationForTxnTopic
-- testOldFindCoordinatorNotEnoughBrokersForOffsetTopic
-- testOldFindCoordinatorNotEnoughBrokersForTxnTopic
-- testProcessShareAcknowledgeResponse
-- testProduceResponseContainsNewLeaderOnNotLeaderOrFollower
-- testProduceResponseMetadataLookupErrorOnNotLeaderOrFollower
-- testProduceResponseReplicaManagerLookupErrorOnNotLeaderOrFollower
-- testPushTelemetry
-- testPushTelemetryNotAllowedForZkClusters
-- testPushTelemetryWithException
-- testRaftShouldAlwaysForwardAlterClientQuotasRequest
-- testRaftShouldAlwaysForwardAlterPartitionReassignmentsRequest
-- testRaftShouldAlwaysForwardAlterUserScramCredentialsRequest
-- testRaftShouldAlwaysForwardCreateAcls
-- testRaftShouldAlwaysForwardCreatePartitionsRequest
-- testRaftShouldAlwaysForwardCreateTokenRequest
-- testRaftShouldAlwaysForwardCreateTopicsRequest
-- testRaftShouldAlwaysForwardDeleteAcls
-- testRaftShouldAlwaysForwardDeleteTopicsRequest
-- testRaftShouldAlwaysForwardElectLeaders
-- testRaftShouldAlwaysForwardExpireTokenRequest
-- testRaftShouldAlwaysForwardListPartitionReassignments
-- testRaftShouldAlwaysForwardRenewTokenRequest
-- testRaftShouldAlwaysForwardUpdateFeatures
-- testRaftShouldNeverHandleAlterPartitionRequest
-- testRaftShouldNeverHandleControlledShutdownRequest
-- testRaftShouldNeverHandleEnvelope
-- testRaftShouldNeverHandleLeaderAndIsrRequest
-- testRaftShouldNeverHandleStopReplicaRequest
-- testRaftShouldNeverHandleUpdateMetadataRequest
-- testReadCommittedConsumerListOffsetLatest
-- testReadShareGroupStateAuthorizationFailed
-- testReadShareGroupStateSuccess
-- testReadUncommittedConsumerListOffsetLatest
-- testReassignmentAndReplicationBytesOutRateWhenNotReassigning
-- testReassignmentAndReplicationBytesOutRateWhenReassigning
-- testRenewDelegationTokenWithForwarding
-- testShareGroupDescribeRequestAuthorizationFailed
-- testShareGroupDescribeRequestAuthorizationFailedForOneGroup
-- testShareGroupDescribeReturnsUnsupportedVersion
-- testShareGroupDescribeSuccess
-- testShareGroupHeartbeatRequest
-- testShareGroupHeartbeatRequestAuthorizationFailed
-- testShareGroupHeartbeatRequestFutureFailed
-- testShareGroupHeartbeatReturnsUnsupportedVersion
-- testSizeOfThrottledPartitions
-- testStopReplicaRequestWithCurrentBrokerEpoch
-- testStopReplicaRequestWithNewerBrokerEpochIsValid
-- testStopReplicaRequestWithStaleBrokerEpochIsRejected
-- testSyncGroupProtocolTypeAndNameAreMandatorySinceV5
-- testTransactionalParametersSetCorrectly
-- testTxnOffsetCommitWithInvalidPartition
-- testUnauthorizedTopicMetadataRequest
-- testUpdateFeaturesWithForwarding
-- testUpdateMetadataRequestWithCurrentBrokerEpoch
-- testUpdateMetadataRequestWithNewerBrokerEpochIsValid
-- testUpdateMetadataRequestWithStaleBrokerEpochIsRejected
-- testWriteShareGroupStateAuthorizationFailed
-- testWriteShareGroupStateSuccess
-- testWriteTxnMarkersShouldAllBeIncludedInTheResponse
-kafka.server.KafkaConfigTest:
-- testAcceptsLargeNodeIdForRaftBasedCase
-- testAcceptsLargeNodeIdForZkBasedCaseWithAutoGenDisabled
-- testAcceptsNegativeOneNodeIdForZkBasedCaseWithAutoGenEnabled
-- testAdvertiseConfigured
-- testAdvertiseDefaults
-- testAdvertisedListenersAllowedForKRaftControllerOnlyRole
-- testBadListenerProtocol
-- testBrokerIdIsInferredByNodeIdWithKraft
-- testCaseInsensitiveListenerProtocol
-- testConsumerGroupHeartbeatIntervalValidation
-- testConsumerGroupMigrationPolicy
-- testConsumerGroupSessionTimeoutValidation
-- testControlPlaneListenerName
-- testControlPlaneListenerNameNotAllowedWithKRaft
-- testControllerListenerDefinedForKRaftBroker
-- testControllerListenerDefinedForKRaftController
-- testControllerListenerNameDoesNotMapToPlaintextByDefaultForNonKRaft
-- testControllerListenerNameMapsToPlaintextByDefaultForKRaft
-- testControllerListenerNames
-- testControllerListenersCanBeAdvertisedForKRaftCombined
-- testControllerQuorumVoterStringsToNodes
-- testCustomMetadataLogDir
-- testDefaultCompressionType
-- testDefaultInterBrokerProtocolVersionKRaft
-- testDefaultMetadataLogDir
-- testDistinctControllerAndAdvertisedListenersAllowedForKRaftBroker
-- testDuplicateListeners
-- testDynamicLogConfigs
-- testEarlyStartListeners
-- testEarlyStartListenersDefault
-- testEarlyStartListenersMustBeListeners
-- testEffectAdvertiseControllerListenerForControllerWithAdvertisement
-- testEffectAdvertiseControllerListenerForControllerWithMixedAdvertisement
-- testEffectAdvertiseControllerListenerForControllerWithoutAdvertisement
-- testEqualAdvertisedListenersProtocol
-- testFromPropsInvalid
-- testGroupCoordinatorRebalanceProtocols
-- testIPv4AndIPv6SamePortListeners
-- testIgnoreUserInterBrokerProtocolVersionKRaft
-- testInterBrokerListenerNameAndSecurityProtocolSet
-- testInterBrokerListenerNameMissingFromListenerSecurityProtocolMap
-- testInterBrokerVersionMessageFormatCompatibility
-- testInvalidAdvertisedListenersProtocol
-- testInvalidAuthorizerClassName
-- testInvalidCompressionType
-- testInvalidGzipCompressionLevel
-- testInvalidInterBrokerProtocolVersionKRaft
-- testInvalidInterBrokerSecurityProtocol
-- testInvalidLz4CompressionLevel
-- testInvalidQuorumVoterConfig
-- testInvalidSecurityInterBrokerProtocol
-- testInvalidZstdCompressionLevel
-- testListenerAndAdvertisedListenerNames
-- testListenerDefaults
-- testListenerNameMissingFromListenerSecurityProtocolMap
-- testListenerNamesWithAdvertisedListenerUnset
-- testLogRetentionTimeBothMinutesAndHoursProvided
-- testLogRetentionTimeBothMinutesAndMsProvided
-- testLogRetentionTimeHoursProvided
-- testLogRetentionTimeMinutesProvided
-- testLogRetentionTimeMsProvided
-- testLogRetentionTimeNoConfigProvided
-- testLogRetentionUnlimited
-- testLogRetentionValid
-- testLogRollTimeBothMsAndHoursProvided
-- testLogRollTimeMsProvided
-- testLogRollTimeNoConfigProvided
-- testMaxConnectionsPerIpProp
-- testMetadataMaxSnapshotInterval
-- testMultipleControllerListenerNamesMapToPlaintextByDefaultForKRaft
-- testNodeIdIsInferredByBrokerIdWithKraft
-- testNodeIdMustNotBeDifferentThanBrokerId
-- testNodeIdOrBrokerIdMustBeSetWithKraft
-- testNonroutableAdvertisedListeners
-- testParseQuorumBootstrapServers
-- testPopulateSynonymsOnEmptyMap
-- testPopulateSynonymsOnMapWithoutBrokerId
-- testPopulateSynonymsOnMapWithoutNodeId
-- testPortInQuorumVotersNotRequiredToMatchFirstControllerListenerPortForThisKRaftController
-- testRejectsLargeNodeIdForZkBasedCaseWithAutoGenEnabled
-- testRejectsNegativeNodeIdForRaftBasedBrokerCaseWithAutoGenEnabled
-- testRejectsNegativeNodeIdForRaftBasedCaseWithAutoGenDisabled
-- testRejectsNegativeNodeIdForRaftBasedControllerCaseWithAutoGenEnabled
-- testRejectsNegativeNodeIdForZkBasedCaseWithAutoGenDisabled
-- testRejectsNegativeTwoNodeIdForZkBasedCaseWithAutoGenEnabled
-- testSaslJwksEndpointRetryDefaults
-- testSeparateControllerListenerDefinedForKRaftBrokerController
-- testShareGroupHeartbeatIntervalValidation
-- testShareGroupRecordLockDurationValidation
-- testShareGroupSessionTimeoutValidation
-- testSingleLogDirectoryWithRemoteLogStorage
-- testSpecificProperties
-- testUncleanElectionDisabled
-- testUncleanElectionEnabled
-- testUncleanElectionInvalid
-- testUncleanLeaderElectionDefault
-- testValidCompressionType
-- testValidEmptyQuorumVotersParsing
-- testValidQuorumVotersParsingWithIpAddress
-- testValidQuorumVotersParsingWithMultipleHost
-- testVersionConfiguration
-- testZookeeperConnectNotRequiredIfNonEmptyProcessRoles
-- testZookeeperConnectRequiredIfEmptyProcessRoles
-kafka.server.KafkaMetricReporterExceptionHandlingTest:
-- testBothReportersAreInvoked
-kafka.server.KafkaMetricsReporterTest:
-- testMetricsContextNamespacePresent
-kafka.server.KafkaRaftServerTest:
-- testKRaftUpdateWithIBP
-- testKRaftUpdateWithoutIBP
-- testLoadMetaPropertiesWithInconsistentNodeId
-- testLoadPropertiesWithInconsistentClusterIds
-- testStartupDoesNotFailIfDataDirIsOffline
-- testStartupFailsIfMetaLogDirIsOffline
-- testStartupFailsIfMetaPropertiesMissingInSomeLogDir
-- testStartupFailsIfUnexpectedMetadataDir
-- testSuccessfulLoadMetaProperties
-kafka.server.KafkaRequestHandlerTest:
-- testCallbackOnSameThread
-- testCallbackTiming
-- testCallbackTryCompleteActions
-- testCopyLagBytesMetricClear
-- testCopyLagBytesMetricWithPartitionExpansion
-- testCopyLagBytesMetricWithPartitionShrinking
-- testCopyLagBytesMetricWithRemovingNonexistentPartitions
-- testCopyLagSegmentsMetricClear
-- testCopyLagSegmentsMetricWithPartitionExpansion
-- testCopyLagSegmentsMetricWithPartitionShrinking
-- testCopyLagSegmentsMetricWithRemovingNonexistentPartitions
-- testDeleteLagBytesMetricClear
-- testDeleteLagBytesMetricWithPartitionExpansion
-- testDeleteLagBytesMetricWithPartitionShrinking
-- testDeleteLagBytesMetricWithRemovingNonexistentPartitions
-- testDeleteLagSegmentsMetricClear
-- testDeleteLagSegmentsMetricWithPartitionExpansion
-- testDeleteLagSegmentsMetricWithPartitionShrinking
-- testDeleteLagSegmentsMetricWithRemovingNonexistentPartitions
-- testGaugeClose
-- testHandlingCallbackOnNewThread
-- testLogSizeBytesMetricClear
-- testLogSizeBytesMetricWithPartitionExpansion
-- testLogSizeBytesMetricWithPartitionShrinking
-- testLogSizeBytesMetricWithRemovingNonexistentPartitions
-- testMultipleCopyLagBytesMetrics
-- testMultipleCopyLagSegmentsMetrics
-- testMultipleDeleteLagBytesMetrics
-- testMultipleDeleteLagSegmentsMetrics
-- testMultipleLogSizeBytesMetrics
-- testRemoteLogMetadataCount
-- testSingularCopyLagBytesMetric
-- testSingularLogSizeBytesMetric
-- testTopicStats
-kafka.server.LeaveGroupRequestTest:
-- testLeaveGroupWithNewConsumerGroupProtocolAndNewGroupCoordinator
-- testLeaveGroupWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testLeaveGroupWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.ListGroupsRequestTest:
-- testListGroupsWithNewConsumerGroupProtocolAndNewGroupCoordinator
-- testListGroupsWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testListGroupsWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.ListOffsetsRequestTest:
-- testCurrentEpochValidation
-- testListOffsetsErrorCodes
-- testResponseDefaultOffsetAndLeaderEpochForAllVersions
-- testResponseIncludesLeaderEpoch
-kafka.server.ListOffsetsRequestWithRemoteStoreTest:
-- testCurrentEpochValidation
-- testListOffsetsErrorCodes
-- testResponseDefaultOffsetAndLeaderEpochForAllVersions
-- testResponseIncludesLeaderEpoch
-kafka.server.LocalLeaderEndPointTest:
-- testFetchEarliestLocalOffset
-- testFetchEarliestOffset
-- testFetchEpochEndOffsets
-- testFetchLatestOffset
-kafka.server.LogDirFailureTest:
-- testIOExceptionDuringCheckpoint
-- testIOExceptionDuringLogRoll
-- testLogDirNotificationTimeout
-- testProduceErrorFromFailureOnCheckpoint
-- testProduceErrorFromFailureOnLogRoll
-- testReplicaFetcherThreadAfterLogDirFailureOnFollower
-kafka.server.LogManagerIntegrationTest:
-- testRestartBrokerNoErrorIfMissingPartitionMetadata
-kafka.server.LogOffsetTest:
-- testEmptyLogsGetOffsets
-- testFetchOffsetByTimestampForMaxTimestampAfterTruncate
-- testFetchOffsetByTimestampForMaxTimestampWithEmptyLog
-- testFetchOffsetByTimestampForMaxTimestampWithUnorderedTimestamps
-- testFetchOffsetsBeforeWithChangingSegmentSize
-- testFetchOffsetsBeforeWithChangingSegments
-- testGetOffsetsAfterDeleteRecords
-- testGetOffsetsBeforeEarliestTime
-- testGetOffsetsBeforeLatestTime
-- testGetOffsetsBeforeNow
-- testGetOffsetsForUnknownTopic
-kafka.server.LogRecoveryTest:
-- testHWCheckpointNoFailuresMultipleLogSegments
-- testHWCheckpointNoFailuresSingleLogSegment
-- testHWCheckpointWithFailuresMultipleLogSegments
-- testHWCheckpointWithFailuresSingleLogSegment
-kafka.server.MetadataCacheTest:
-- getAliveBrokersShouldNotBeMutatedByUpdateCache
-- getTopicMetadata
-- getTopicMetadataIsrNotAvailable
-- getTopicMetadataNonExistingTopics
-- getTopicMetadataPartitionLeaderNotAvailable
-- getTopicMetadataPartitionListenerNotAvailableOnLeader
-- getTopicMetadataReplicaNotAvailable
-- getTopicMetadataWithNonSupportedSecurityProtocol
-- testCreateDeletionEntries
-- testGetAliveBrokersWithBrokerFenced
-- testGetClusterMetadataWithOfflineReplicas
-- testGetLiveBrokerEpoch
-- testGetOfflineReplicasConsidersDirAssignment
-- testGetPartitionInfo
-- testGetTopicMetadataForDescribeTopicPartitionsResponse
-- testIsBrokerFenced
-- testIsBrokerInControlledShutdown
-- testUpdateZkMetadataCacheViaHybridUMR
-- testUpdateZkMetadataCacheWithRecreatedTopic
-- transformUMRWithBuggySnapshot
-- transformUMRWithMissingBar
-- transformUMRWithNoChanges
-- transformUMRWithRecreatedBar
-kafka.server.MetadataRequestTest:
-- testAliveBrokersWithNoTopics
-- testAllTopicsRequest
-- testAutoCreateTopicWithInvalidReplicationFactor
-- testAutoTopicCreation
-- testClusterIdIsValid
-- testClusterIdWithRequestVersion1
-- testIsInternal
-- testIsrAfterBrokerShutDownAndJoinsBack
-- testNoTopicsRequest
-- testPreferredReplica
-- testRack
-- testReplicaDownResponse
-- testTopicIdsInResponse
-kafka.server.MetadataVersionConfigValidatorTest:
-- testInvokesFaultHandlerOnException
-- testValidatesConfigOnMetadataChange
-kafka.server.MetadataVersionIntegrationTest:
-- testBasicMetadataVersionUpgrade
-- testDefaultIsLatestVersion
-- testUpgradeSameVersion
-kafka.server.MultipleListenersWithAdditionalJaasContextTest:
-- testProduceConsume
-kafka.server.MultipleListenersWithDefaultJaasContextTest:
-- testProduceConsume
-kafka.server.NodeToControllerRequestThreadTest:
-- testAuthenticationExceptionHandling
-- testControllerChanged
-- testEnvelopeResponseWithNotControllerError
-- testNotController
-- testRequestsSent
-- testRetryTimeout
-- testRetryTimeoutWhileControllerNotAvailable
-- testThreadNotStarted
-- testUnsupportedVersionHandling
-kafka.server.OffsetCommitRequestTest:
-- testOffsetCommitWithNewConsumerGroupProtocolAndNewGroupCoordinator
-- testOffsetCommitWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testOffsetCommitWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.OffsetDeleteRequestTest:
-- testOffsetDeleteWithNewConsumerGroupProtocolAndNewGroupCoordinator
-- testOffsetDeleteWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testOffsetDeleteWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.OffsetFetchRequestTest:
-- testMultiGroupsOffsetFetchWithNewConsumerGroupProtocolAndNewGroupCoordinator
-- testMultiGroupsOffsetFetchWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testMultiGroupsOffsetFetchWithOldConsumerGroupProtocolAndOldGroupCoordinator
-- testSingleGroupAllOffsetFetchWithNewConsumerGroupProtocolAndNewGroupCoordinator
-- testSingleGroupAllOffsetFetchWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testSingleGroupAllOffsetFetchWithOldConsumerGroupProtocolAndOldGroupCoordinator
-- testSingleGroupOffsetFetchWithNewConsumerGroupProtocolAndNewGroupCoordinator
-- testSingleGroupOffsetFetchWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testSingleGroupOffsetFetchWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.OffsetsForLeaderEpochRequestTest:
-- testCurrentEpochValidation
-- testOffsetsForLeaderEpochErrorCodes
-kafka.server.PermissiveControllerMutationQuotaTest:
-- testControllerMutationQuotaViolation
-kafka.server.ProduceRequestTest:
-- quorum
-- testCorruptLz4ProduceRequest
-- testProduceToNonReplica
-- testSimpleProduceRequest
-- testZSTDProduceRequest
-kafka.server.RaftClusterSnapshotTest:
-- testSnapshotsGenerated
-kafka.server.ReconfigurableQuorumIntegrationTest:
-- testCreateAndDestroyNonReconfigurableCluster
-- testCreateAndDestroyReconfigurableCluster
-- testRemoveAndAddSameController
-- testRemoveController
-kafka.server.RemoteLeaderEndPointTest:
-- testBrokerEpochSupplier
-- testFetchEarliestLocalOffset
-- testFetchEarliestOffset
-- testFetchEpochEndOffsets
-- testFetchLatestOffset
-- testThrowsFencedLeaderEpochException
-- testThrowsUnknownLeaderEpochException
-kafka.server.ReplicaAlterLogDirsThreadTest:
-- fetchEpochsFromLeaderShouldHandleExceptionFromGetLocalReplica
-- issuesEpochRequestFromLocalReplica
-- shouldFetchLeaderEpochOnFirstFetchOnly
-- shouldFetchNonDelayedAndNonTruncatingReplicas
-- shouldFetchOneReplicaAtATime
-- shouldNotAddPartitionIfFutureLogIsNotDefined
-- shouldPollIndefinitelyIfReplicaNotAvailable
-- shouldReplaceCurrentLogDirWhenCaughtUp
-- shouldReplaceCurrentLogDirWhenCaughtUpWithAfterAssignmentRequestHasBeenCompleted
-- shouldRevertAnyScheduledAssignmentRequestIfAssignmentIsCancelled
-- shouldRevertReassignmentsForIncompleteFutureReplicaPromotions
-- shouldTruncateToEndOffsetOfLargestCommonEpoch
-- shouldTruncateToInitialFetchOffsetIfReplicaReturnsUndefinedOffset
-- shouldTruncateToReplicaOffset
-- shouldUpdateLeaderEpochAfterFencedEpochError
-kafka.server.ReplicaFetchTest:
-- testReplicaFetcherThread
-kafka.server.ReplicaFetcherThreadTest:
-- shouldCatchExceptionFromBlockingSendWhenShuttingDownReplicaFetcherThread
-- shouldFetchLeaderEpochOnFirstFetchOnlyIfLeaderEpochKnownToBothIbp26
-- shouldFetchLeaderEpochSecondTimeIfLeaderRepliesWithEpochNotKnownToFollower
-- shouldFilterPartitionsMadeLeaderDuringLeaderEpochRequest
-- shouldHandleExceptionFromBlockingSend
-- shouldMovePartitionsOutOfTruncatingLogState
-- shouldNotFetchLeaderEpochOnFirstFetchWithTruncateOnFetch
-- shouldNotUpdateReassignmentBytesInMetricsWhenNoReassignmentsInProgress
-- shouldPollIndefinitelyIfLeaderReturnsAnyException
-- shouldSendLatestRequestVersionsByDefault
-- shouldTruncateIfLeaderRepliesWithDivergingEpochNotKnownToFollower
-- shouldTruncateToInitialFetchOffsetIfLeaderReturnsUndefinedOffset
-- shouldTruncateToOffsetSpecifiedInEpochOffsetResponse
-- shouldTruncateToOffsetSpecifiedInEpochOffsetResponseIfFollowerHasNoMoreEpochs
-- shouldUpdateReassignmentBytesInMetrics
-- shouldUseLeaderEndOffsetIfInterBrokerVersionBelow20
-- testBuildFetch
-- testFetchLeaderEpochRequestIfLastEpochDefinedForSomePartitions
-- testLagIsUpdatedWhenNoRecords
-- testLocalFetchCompletionIfHighWatermarkUpdated
-- testTruncateOnFetchDoesNotUpdateHighWatermark
-kafka.server.ReplicaManagerConcurrencyTest:
-- testIsrExpandAndShrinkWithConcurrentProduce
-kafka.server.ReplicaManagerQuotasTest:
-- shouldExcludeSubsequentThrottledPartitions
-- shouldGetBothMessagesIfQuotasAllow
-- shouldGetNoMessagesIfQuotasExceededOnSubsequentPartitions
-- shouldIncludeInSyncThrottledReplicas
-- shouldIncludeThrottledReplicasForConsumerFetch
-- testCompleteInDelayedFetchConsumerFetch
-- testCompleteInDelayedFetchWithReplicaThrottling
kafka.server.ReplicaManagerTest:
-- checkRemoveMetricsCountMatchRegisterCount
-- testActiveProducerState
-- testApplyDeltaShouldHandleReplicaAssignedToLostDirectory
-- testApplyDeltaShouldHandleReplicaAssignedToOnlineDirectory
-- testApplyDeltaShouldHandleReplicaAssignedToUnassignedDirectory
- testBecomeFollowerInvokeOnBecomingFollowerListener
-- testBecomeFollowerWhenLeaderIsUnchangedButMissedLeaderUpdate
-- testBecomeFollowerWhenLeaderIsUnchangedButMissedLeaderUpdateIbp26
-- testBecomeFollowerWhileNewClientFetchInPurgatory
-- testBecomeFollowerWhileOldClientFetchInPurgatory
-- testBuildRemoteLogAuxStateMetricsThrowsException
-- testCheckpointHwOnShutdown
-- testClearFetchPurgatoryOnStopReplica
-- testClearProducePurgatoryOnStopReplica
-- testClearPurgatoryOnBecomingFollower
-- testDefaultReplicaSelector
-- testDelayedFetchIncludesAbortedTransactions
-- testDeleteRecordsInternalTopicDeleteAllowed
-- testDeleteRecordsInternalTopicDeleteDisallowed
-- testDeltaFollowerRemovedTopic
-- testDeltaFollowerStopFetcherBeforeCreatingInitialFetchOffset
-- testDeltaFollowerToNotReplica
-- testDeltaFollowerWithNoChange
-- testDeltaFromFollowerToLeader
-- testDeltaFromLeaderToFollower
-- testDeltaLeaderToNotReplica
-- testDeltaLeaderToRemovedTopic
-- testDeltaToFollowerCompletesFetch
-- testDeltaToFollowerCompletesProduce
-- testDeltaToLeaderOrFollowerMarksPartitionOfflineIfLogCantBeCreated
-- testDescribeLogDirs
-- testDescribeLogDirsWithoutAnyPartitionTopic
-- testDisabledTransactionVerification
-- testExceptionWhenUnverifiedTransactionHasMultipleProducerIds
-- testFailedBuildRemoteLogAuxStateMetrics
-- testFencedErrorCausedByBecomeLeader
-- testFetchBeyondHighWatermark
-- testFetchFollowerNotAllowedForOlderClients
-- testFetchFromFollowerShouldNotRunPreferLeaderSelect
-- testFetchFromLeaderAlwaysAllowed
-- testFetchMessagesWhenNotFollowerForOnePartition
-- testFetchMessagesWithInconsistentTopicId
-- testFetchRequestRateMetrics
-- testFetchShouldReturnImmediatelyWhenPreferredReadReplicaIsDefined
-- testFetcherAreNotRestartedIfLeaderEpochIsNotBumpedWithKRaftPath
-- testFollowerFetchWithDefaultSelectorNoForcedHwPropagation
-- testFollowerStateNotUpdatedIfLogReadFails
-- testFullLeaderAndIsrStrayPartitions
-- testGetOrCreatePartition
-- testGetOrCreatePartitionShouldNotCreateOfflinePartition
-- testHighWaterMarkDirectoryMapping
-- testHighwaterMarkRelativeDirectoryMapping
-- testIllegalRequiredAcks
-- testInconsistentIdReturnsError
-- testMaybeAddLogDirFetchersPausingCleaning
-- testMaybeAddLogDirFetchersWithoutEpochCache
-- testNotCallStopPartitionsForNonTieredTopics
-- testOffsetOutOfRangeExceptionWhenFetchMessages
-- testOffsetOutOfRangeExceptionWhenReadFromLog
-- testOldFollowerLosesMetricsWhenReassignPartitions
-- testOldLeaderLosesMetricsWhenReassignPartitions
-- testPartitionFetchStateUpdatesWithTopicIdChanges
-- testPartitionListener
-- testPartitionMarkedOfflineIfLogCantBeCreated
-- testPartitionMetadataFile
-- testPartitionMetadataFileCreatedAfterPreviousRequestWithoutIds
-- testPartitionMetadataFileCreatedWithExistingLog
-- testPartitionMetadataFileNotCreated
-- testPartitionsWithLateTransactionsCount
-- testPreVerificationError
-- testPreferredReplicaAsFollower
-- testPreferredReplicaAsLeader
-- testPreferredReplicaAsLeaderWhenSameRackFollowerIsOutOfIsr
-- testProducerIdCountMetrics
-- testReadCommittedFetchLimitedAtLSO
-- testReceiveOutOfOrderSequenceExceptionWithLogStartOffset
-- testRemoteFetchExpiresPerSecMetric
-- testRemoteLogReaderMetrics
-- testRemoteReadQuotaExceeded
-- testRemoteReadQuotaNotExceeded
-- testReplicaAlterLogDirsWithAndWithoutIds
-- testReplicaNotAvailable
-- testReplicaSelector
-- testReplicasAreStoppedWhileInControlledShutdownWithKRaft
-- testStopReplicaWithDeletePartitionAndExistingPartitionAndDeleteSentinel
-- testStopReplicaWithDeletePartitionAndExistingPartitionAndEqualLeaderEpoch
-- testStopReplicaWithDeletePartitionAndExistingPartitionAndLeaderEpochNotProvided
-- testStopReplicaWithDeletePartitionAndExistingPartitionAndNewerLeaderEpoch
-- testStopReplicaWithDeletePartitionAndExistingPartitionAndNewerLeaderEpochAndIOException
-- testStopReplicaWithDeletePartitionAndExistingPartitionAndOlderLeaderEpoch
-- testStopReplicaWithExistingPartitionAndDeleteSentinel
-- testStopReplicaWithExistingPartitionAndEqualLeaderEpoch
-- testStopReplicaWithExistingPartitionAndLeaderEpochNotProvided
-- testStopReplicaWithExistingPartitionAndNewerLeaderEpoch
-- testStopReplicaWithExistingPartitionAndOlderLeaderEpoch
-- testStopReplicaWithInexistentPartition
-- testStopReplicaWithInexistentPartitionAndPartitionsDelete
-- testStopReplicaWithInexistentPartitionAndPartitionsDeleteAndIOException
-- testStopReplicaWithOfflinePartition
-- testStopReplicaWithStaleControllerEpoch
-- testSuccessfulBuildRemoteLogAuxStateMetrics
-- testTransactionVerificationBlocksOutOfOrderSequence
-- testTransactionVerificationDynamicDisablement
-- testTransactionVerificationFlow
-- testTransactionVerificationGuardOnMultiplePartitions
-- testTransactionVerificationWhenNotLeader
-- testUnknownReplicaSelector
-- testUpdateStrayLogs
-- testVerificationErrorConversions
-- testVerificationForTransactionalPartitionsOnly
-kafka.server.ReplicationQuotaManagerTest:
-- shouldExceedQuotaThenReturnBackBelowBoundAsTimePasses
-- shouldSupportWildcardThrottledReplicas
-- shouldThrottleOnlyDefinedReplicas
-kafka.server.ReplicationQuotasTest:
-- shouldBootstrapTwoBrokersWithFollowerThrottle
-- shouldBootstrapTwoBrokersWithLeaderThrottle
-- shouldThrottleOldSegments
-kafka.server.RequestQuotaTest:
-- testExemptRequestTime
-- testResponseThrottleTime
-- testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated
-- testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated
-- testUnauthorizedThrottle
-- testUnthrottledClient
-kafka.server.ServerMetricsTest:
-- testMetricsConfig
-kafka.server.ServerShutdownTest:
-- testCleanShutdown
-- testCleanShutdownAfterFailedStartup
-- testConsecutiveShutdown
-- testNoCleanShutdownAfterFailedStartupDueToCorruptLogs
-- testShutdownWithKRaftControllerUnavailable
-kafka.server.ServerTest:
-- testCreateSelfManagedKafkaMetricsContext
-- testCreateZkKafkaMetricsContext
-kafka.server.ShareFetchAcknowledgeRequestTest:
-- testShareAcknowledgeInitialRequestError
-- testShareAcknowledgeRequestInvalidShareSessionEpoch
-- testShareAcknowledgeRequestIsInAccessibleWhenConfigsDisabled
-- testShareAcknowledgeRequestMaxDeliveryAttemptExhausted
-- testShareAcknowledgeRequestShareSessionNotFound
-- testShareAcknowledgeRequestSuccessAccept
-- testShareAcknowledgeRequestSuccessReject
-- testShareAcknowledgeRequestSuccessRelease
-- testShareFetchBrokerRespectsPartitionsSizeLimit
-- testShareFetchInitialEpochWithAcknowledgements
-- testShareFetchRequestForgetTopicPartitions
-- testShareFetchRequestInvalidShareSessionEpoch
-- testShareFetchRequestIsInAccessibleWhenConfigsDisabled
-- testShareFetchRequestNoSharingBetweenMultipleConsumersFromDifferentGroups
-- testShareFetchRequestPiggybackedAccept
-- testShareFetchRequestPiggybackedReject
-- testShareFetchRequestPiggybackedRelease
-- testShareFetchRequestShareSessionNotFound
-- testShareFetchRequestSuccess
-- testShareFetchRequestSuccessMultiplePartitions
-- testShareFetchRequestSuccessMultiplePartitionsMultipleBrokers
-- testShareFetchRequestSuccessfulSharingBetweenMultipleConsumers
-- testShareFetchRequestToNonLeaderReplica
-- testShareSessionCloseWithShareAcknowledge
-- testShareSessionCloseWithShareFetch
-kafka.server.ShareGroupDescribeRequestTest:
-- testShareGroupDescribe
-- testShareGroupDescribeIsInAccessibleWhenConfigsDisabled
-kafka.server.ShareGroupHeartbeatRequestTest:
-- testGroupCoordinatorChange
-- testMemberJoiningAndExpiring
-- testMemberLeavingAndRejoining
-- testPartitionAssignmentWithChangingTopics
-- testShareGroupHeartbeatIsAccessibleWhenShareGroupIsEnabled
-- testShareGroupHeartbeatIsInAccessibleWhenConfigsDisabled
-- testShareGroupHeartbeatWithMultipleMembers
-kafka.server.StrictControllerMutationQuotaTest:
-- testControllerMutationQuotaViolation
-kafka.server.SyncGroupRequestTest:
-- testSyncGroupWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testSyncGroupWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.ThrottledChannelExpirationTest:
-- testCallbackInvocationAfterExpiration
-kafka.server.TierStateMachineTest:
-- testFencedOffsetResetAfterMovedToRemoteTier
-- testFollowerFetchMovedToTieredStore
-- testFollowerFetchOffsetOutOfRangeWithTieredStore
kafka.server.TxnOffsetCommitRequestTest:
- testTxnOffsetCommitWithNewConsumerGroupProtocolAndNewGroupCoordinator
- testTxnOffsetCommitWithOldConsumerGroupProtocolAndNewGroupCoordinator
- testTxnOffsetCommitWithOldConsumerGroupProtocolAndOldGroupCoordinator
-kafka.server.epoch.LeaderEpochFileCacheTest:
-- shouldAddEpochAndMessageOffsetToCache
-- shouldClearAllEntries
-- shouldClearEarliestOnEmptyCache
-- shouldClearLatestOnEmptyCache
-- shouldDropEntriesBetweenEpochBoundaryWhenRemovingNewest
-- shouldDropEntriesOnEpochBoundaryWhenRemovingLatestEntries
-- shouldEnforceMonotonicallyIncreasingEpochs
-- shouldEnforceMonotonicallyIncreasingStartOffsets
-- shouldEnforceOffsetsIncreaseMonotonically
-- shouldFetchEndOffsetOfEmptyCache
-- shouldFetchEpochForGivenOffset
-- shouldFetchLatestEpochOfEmptyCache
-- shouldGetFirstOffsetOfSubsequentEpochWhenOffsetRequestedForPreviousEpoch
-- shouldIncreaseAndTrackEpochsAsFollowerReceivesManyMessages
-- shouldIncreaseAndTrackEpochsAsLeadersChangeManyTimes
-- shouldNotClearAnythingIfOffsetToEarly
-- shouldNotClearAnythingIfOffsetToFirstOffset
-- shouldNotOverwriteLogEndOffsetForALeaderEpochOnceItHasBeenAssigned
-- shouldNotOverwriteOffsetForALeaderEpochOnceItHasBeenAssigned
-- shouldNotResetEpochHistoryHeadIfUndefinedPassed
-- shouldNotResetEpochHistoryTailIfUndefinedPassed
-- shouldNotUpdateEpochAndStartOffsetIfItDidNotChange
-- shouldPersistEpochsBetweenInstances
-- shouldPreserveResetOffsetOnClearEarliestIfOneExists
-- shouldRetainLatestEpochOnClearAllEarliest
-- shouldRetainLatestEpochOnClearAllEarliestAndUpdateItsOffset
-- shouldReturnFirstEpochIfRequestedEpochLessThanFirstEpoch
-- shouldReturnInvalidOffsetIfEpochIsRequestedWhichIsNotCurrentlyTracked
-- shouldReturnLogEndOffsetIfLatestEpochRequested
-- shouldReturnNextAvailableEpochIfThereIsNoExactEpochForTheOneRequested
-- shouldReturnUndefinedOffsetIfUndefinedEpochRequested
-- shouldReturnUnsupportedIfNoEpochRecorded
-- shouldReturnUnsupportedIfNoEpochRecordedAndUndefinedEpochRequested
-- shouldSupportEpochsThatDoNotStartFromZero
-- shouldTruncateIfMatchingEpochButEarlierStartingOffset
-- shouldUpdateOffsetBetweenEpochBoundariesOnClearEarliest
-- shouldUpdateOffsetBetweenEpochBoundariesOnClearEarliest2
-- shouldUpdateSavedOffsetWhenOffsetToClearToIsBetweenEpochs
-- shouldWriteCheckpointOnTruncation
-- testFindNextEpoch
-- testFindPreviousEntry
-- testFindPreviousEpoch
-- testGetEpochEntry
-- testPreviousEpoch
-kafka.server.epoch.LeaderEpochIntegrationTest:
-- shouldAddCurrentLeaderEpochToMessagesAsTheyAreWrittenToLeader
-- shouldIncreaseLeaderEpochBetweenLeaderRestarts
-- shouldSendLeaderEpochRequestAndGetAResponse
-kafka.server.epoch.OffsetsForLeaderEpochTest:
-- shouldGetEpochsFromReplica
-- shouldReturnNoLeaderForPartitionIfThrown
-- shouldReturnUnknownTopicOrPartitionIfThrown
-kafka.server.handlers.DescribeTopicPartitionsRequestHandlerTest:
-- testDescribeTopicPartitionsRequest
-- testDescribeTopicPartitionsRequestWithEdgeCases
-kafka.server.logger.RuntimeLoggerManagerTest:
-- testOperationNotAllowed
-- testValidateBogusLogLevelNameNotAllowed
-- testValidateDeleteLogLevelConfig
-- testValidateRemoveRootLogLevelConfigNotAllowed
-- testValidateSetLogLevelConfig
-- testValidateSetRootLogLevelConfig
-kafka.server.metadata.BrokerMetadataPublisherTest:
-- testExceptionInUpdateCoordinator
-- testGetTopicDelta
-- testNewImagePushedToGroupCoordinator
-- testReloadUpdatedFilesWithoutConfigChange
-kafka.server.metadata.MockConfigRepositoryTest:
-- testEmptyRepository
-- testSetTopicConfig
-kafka.server.share.DelayedShareFetchTest:
-- testCombineLogReadResponse
-- testDelayedShareFetchTryCompleteReturnsFalseDueToNonAcquirablePartitions
-- testDelayedShareFetchTryCompleteReturnsTrue
-- testEmptyFutureReturnedByDelayedShareFetchOnComplete
-- testExceptionInMinBytesCalculation
-- testForceCompleteTriggersDelayedActionsQueue
-- testLocksReleasedAcquireException
-- testLocksReleasedForCompletedFetch
-- testReplicaManagerFetchShouldHappenOnComplete
-- testToCompleteAnAlreadyCompletedFuture
-- testTryCompleteWhenMinBytesNotSatisfiedOnFirstFetch
-- testTryCompleteWhenMinBytesNotSatisfiedOnSubsequentFetch
-kafka.server.share.ShareFetchUtilsTest:
-- testProcessFetchResponse
-- testProcessFetchResponseWhenNoRecordsAreAcquired
-- testProcessFetchResponseWithEmptyRecords
-- testProcessFetchResponseWithLsoMovementForTopicPartition
-- testProcessFetchResponseWithMaxFetchRecords
-- testProcessFetchResponseWithOffsetFetchException
kafka.server.share.SharePartitionManagerTest:
-- testAcknowledgeCompletesDelayedShareFetchRequest
-- testAcknowledgeDoesNotCompleteDelayedShareFetchRequest
-- testAcknowledgeEmptyPartitionCacheMap
-- testAcknowledgeIncorrectGroupId
-- testAcknowledgeIncorrectMemberId
-- testAcknowledgeMultiplePartition
-- testAcknowledgeSinglePartition
-- testCachedTopicPartitionsForValidShareSessions
-- testCachedTopicPartitionsWithNoTopicPartitions
-- testCloseSharePartitionManager
-- testDelayedInitializationShouldCompleteFetchRequest
-- testGetErroneousAndValidTopicIdPartitions
- testListenerRegistration
-- testMultipleConcurrentShareFetches
-- testMultipleSequentialShareFetches
-- testNewContext
-- testNewContextReturnsFinalContextError
-- testNewContextReturnsFinalContextWithRequestData
-- testNewContextReturnsFinalContextWithoutRequestData
-- testPendingInitializationShouldCompleteFetchRequest
-- testReleaseSessionCompletesDelayedShareFetchRequest
-- testReleaseSessionDoesNotCompleteDelayedShareFetchRequest
-- testReleaseSessionSuccess
-- testReleaseSessionWithEmptyTopicPartitions
-- testReleaseSessionWithIncorrectGroupId
-- testReleaseSessionWithIncorrectMemberId
-- testReleaseSessionWithNullShareSession
-- testReplicaManagerFetchException
-- testReplicaManagerFetchMultipleSharePartitionsException
-- testReplicaManagerFetchShouldNotProceed
-- testReplicaManagerFetchShouldProceed
-- testShareFetchContextResponseSize
-- testShareFetchProcessingExceptions
-- testSharePartitionInitializationExceptions
-- testSharePartitionInitializationFailure
-- testSharePartitionKey
- testSharePartitionListenerOnBecomingFollower
- testSharePartitionListenerOnDeleted
- testSharePartitionListenerOnFailed
-- testSharePartitionPartialInitializationFailure
-- testShareSessionExpiration
-- testShareSessionUpdateTopicIdsBrokerSide
-- testSubsequentShareSession
-- testToForgetPartitions
-- testZeroSizeShareSession
-kafka.server.share.SharePartitionTest:
-- testAcknowledgeAfterAcquisitionLockTimeout
-- testAcknowledgeBatchAndOffsetPostLsoMovement
-- testAcknowledgeBatchPostLsoMovement
-- testAcknowledgeBatchWithWriteShareGroupStateFailure
-- testAcknowledgeMultipleRecordBatch
-- testAcknowledgeMultipleRecordBatchWithGapOffsets
-- testAcknowledgeMultipleSubsetRecordBatchWithGapOffsets
-- testAcknowledgeOffsetWithWriteShareGroupStateFailure
-- testAcknowledgeOutOfRangeCachedData
-- testAcknowledgeOutOfRangeCachedDataFirstBatch
-- testAcknowledgeRollbackWithFullBatchError
-- testAcknowledgeRollbackWithSubsetError
-- testAcknowledgeSingleRecordBatch
-- testAcknowledgeSubsetWithAnotherMember
-- testAcknowledgeWhenOffsetNotAcquired
-- testAcknowledgeWithAnotherMember
-- testAcknowledgeWithAnotherMemberRollbackBatchError
-- testAcknowledgeWithAnotherMemberRollbackSubsetError
-- testAcquireMultipleRecords
-- testAcquireMultipleRecordsWithOverlapAndNewBatch
-- testAcquireReleasedRecord
-- testAcquireReleasedRecordMultipleBatches
-- testAcquireSameBatchAgain
-- testAcquireSingleRecord
-- testAcquireWithEmptyFetchRecords
-- testAcquireWithMaxFetchRecords
-- testAcquireWithMultipleBatchesAndMaxFetchRecords
-- testAcquireWithWriteShareGroupStateDelay
-- testAcquisitionLockAfterDifferentAcknowledges
-- testAcquisitionLockForAcquiringMultipleRecords
-- testAcquisitionLockForAcquiringMultipleRecordsWithOverlapAndNewBatch
-- testAcquisitionLockForAcquiringSameBatchAgain
-- testAcquisitionLockForAcquiringSingleRecord
-- testAcquisitionLockForAcquiringSubsetBatchAgain
-- testAcquisitionLockOnAcknowledgingMultipleRecordBatch
-- testAcquisitionLockOnAcknowledgingMultipleRecordBatchWithGapOffsets
-- testAcquisitionLockOnAcknowledgingMultipleSubsetRecordBatchWithGapOffsets
-- testAcquisitionLockOnAcknowledgingSingleRecordBatch
-- testAcquisitionLockOnBatchWithWriteShareGroupStateFailure
-- testAcquisitionLockOnOffsetWithWriteShareGroupStateFailure
-- testAcquisitionLockOnReleasingAcknowledgedMultipleSubsetRecordBatchWithGapOffsets
-- testAcquisitionLockOnReleasingMultipleRecordBatch
-- testAcquisitionLockTimeoutCauseMaxDeliveryCountExceed
-- testAcquisitionLockTimeoutCauseSPSOMoveForward
-- testAcquisitionLockTimeoutCauseSPSOMoveForwardAndClearCachedState
-- testAcquisitionLockTimeoutForBatchesPostStartOffsetMovement
-- testAcquisitionLockTimeoutForBatchesPostStartOffsetMovementToMiddleOfBatch
-- testAcquisitionLockTimeoutForBatchesPostStartOffsetMovementToStartOfBatch
-- testCanAcquireRecordsAfterAcceptAcknowledgement
-- testCanAcquireRecordsAfterArchiveAcknowledgement
-- testCanAcquireRecordsAfterReleaseAcknowledgement
-- testCanAcquireRecordsChangeResponsePostAcknowledgement
-- testCanAcquireRecordsReturnsTrue
-- testCanAcquireRecordsWithCachedDataAndLimitNotReached
-- testCanAcquireRecordsWithCachedDataAndLimitReached
-- testCanAcquireRecordsWithEmptyCache
-- testLsoMovementAheadOfEndOffset
-- testLsoMovementAheadOfEndOffsetPostAcknowledgment
-- testLsoMovementForArchivingBatches
-- testLsoMovementForArchivingOffsets
-- testLsoMovementForArchivingOffsetsWithStartAndEndBatchesNotFullMatches
-- testLsoMovementForArchivingOffsetsWithStartOffsetNotFullMatches
-- testLsoMovementForArchivingOffsetsWithStartOffsetNotFullMatchesPostAcceptAcknowledgement
-- testLsoMovementForArchivingOffsetsWithStartOffsetNotFullMatchesPostReleaseAcknowledgement
-- testLsoMovementOnInitializationSharePartition
-- testLsoMovementPostGapsInAcknowledgments
-- testLsoMovementThenAcquisitionLockTimeoutThenAcknowledge
-- testLsoMovementThenAcquisitionLockTimeoutThenAcknowledgeBatchLastOffsetAheadOfStartOffsetBatch
-- testLsoMovementToEndOffset
-- testLsoMovementToEndOffsetWhereEndOffsetIsAvailable
-- testLsoMovementWithGapsInCachedStateMap
-- testLsoMovementWithGapsInCachedStateMapAndAcknowledgedBatch
-- testMaxDeliveryCountLimitExceededForRecordBatch
-- testMaxDeliveryCountLimitExceededForRecordsSubset
-- testMaxDeliveryCountLimitExceededForRecordsSubsetAfterReleaseAcquiredRecords
-- testMaxDeliveryCountLimitExceededForRecordsSubsetAfterReleaseAcquiredRecordsSubset
-- testMaxDeliveryCountLimitExceededForRecordsSubsetAndCachedStateNotCleared
-- testMaxDeliveryCountLimitExceededForRecordsSubsetCacheCleared
-- testMaybeAcquireAndReleaseFetchLock
-- testMaybeInitialize
-- testMaybeInitializeDefaultStartEpochGroupConfigNotPresent
-- testMaybeInitializeDefaultStartEpochGroupConfigReturnsByDuration
-- testMaybeInitializeDefaultStartEpochGroupConfigReturnsEarliest
-- testMaybeInitializeDefaultStartEpochGroupConfigReturnsLatest
-- testMaybeInitializeFetchOffsetForByDurationThrowsError
-- testMaybeInitializeFetchOffsetForEarliestTimestampThrowsError
-- testMaybeInitializeFetchOffsetForLatestTimestampThrowsError
-- testMaybeInitializeSharePartitionAgain
-- testMaybeInitializeSharePartitionAgainConcurrentRequests
-- testMaybeInitializeWhenReadStateRpcReturnsZeroAvailableRecords
-- testMaybeInitializeWithEmptyStateBatches
-- testMaybeInitializeWithEmptyTopicsData
-- testMaybeInitializeWithErrorPartitionResponse
-- testMaybeInitializeWithInvalidPartitionResponse
-- testMaybeInitializeWithInvalidStartOffsetStateBatches
-- testMaybeInitializeWithInvalidTopicIdResponse
-- testMaybeInitializeWithNoOpShareStatePersister
-- testMaybeInitializeWithNullResponse
-- testMaybeInitializeWithNullTopicsData
-- testMaybeInitializeWithReadException
-- testMaybeUpdateCachedStateMultipleAcquisitionsAndAcknowledgements
-- testMaybeUpdateCachedStateWhenAcknowledgementTypeAccept
-- testMaybeUpdateCachedStateWhenAcknowledgementTypeReject
-- testMaybeUpdateCachedStateWhenAcknowledgementTypeRelease
-- testMaybeUpdateCachedStateWhenAcknowledgementsFromBeginningForBatchSubset
-- testMaybeUpdateCachedStateWhenAcknowledgementsFromBeginningForEntireBatch
-- testMaybeUpdateCachedStateWhenAcknowledgementsInBetween
-- testMaybeUpdateCachedStateWhenAllRecordsInCachedStateAreAcknowledged
-- testNextFetchOffsetInitialState
-- testNextFetchOffsetPostAcquireAndAcknowledgeFunctionality
-- testNextFetchOffsetWithCachedStateAcquired
-- testNextFetchOffsetWithFindAndCachedState
-- testNextFetchOffsetWithFindAndCachedStateEmpty
-- testNextFetchOffsetWithMultipleConsumers
-- testNumberOfWriteCallsOnUpdates
-- testReacquireSubsetWithAnotherMember
-- testRecordStateForId
-- testRecordStateValidateTransition
-- testReleaseAcknowledgedMultipleSubsetRecordBatch
-- testReleaseAcquiredRecordsAfterDifferentAcknowledges
-- testReleaseAcquiredRecordsBatchesPostStartOffsetMovement
-- testReleaseAcquiredRecordsBatchesPostStartOffsetMovementToMiddleOfBatch
-- testReleaseAcquiredRecordsBatchesPostStartOffsetMovementToStartOfBatch
-- testReleaseAcquiredRecordsForEmptyCachedData
-- testReleaseAcquiredRecordsSubsetWithAnotherMember
-- testReleaseAcquiredRecordsWithAnotherMember
-- testReleaseAcquiredRecordsWithAnotherMemberAndSubsetAcknowledged
-- testReleaseBatchWithWriteShareGroupStateFailure
-- testReleaseMultipleAcknowledgedRecordBatch
-- testReleaseMultipleRecordBatch
-- testReleaseOffsetWithWriteShareGroupStateFailure
-- testReleaseSingleRecordBatch
-- testScheduleAcquisitionLockTimeoutValueFromGroupConfig
-- testScheduleAcquisitionLockTimeoutValueUpdatesSuccessfully
-- testWriteShareGroupState
-- testWriteShareGroupStateFailure
-- testWriteShareGroupStateWithInvalidTopicsData
-- testWriteShareGroupStateWithNoOpShareStatePersister
-- testWriteShareGroupStateWithNullResponse
-- testWriteShareGroupStateWithNullTopicsData
-- testWriteShareGroupStateWithWriteException
-kafka.test.api.ShareConsumerTest:
-- testAcknowledgementCommitCallbackCallsShareConsumerDisallowed
-- testAcknowledgementCommitCallbackCallsShareConsumerWakeup
-- testAcknowledgementCommitCallbackInvalidRecordStateException
-- testAcknowledgementCommitCallbackOnClose
-- testAcknowledgementCommitCallbackSuccessfulAcknowledgement
-- testAcknowledgementCommitCallbackThrowsException
-- testAcknowledgementSentOnSubscriptionChange
-- testAcquisitionLockTimeoutOnConsumer
-- testConsumerCloseInGroupSequential
-- testControlRecordsSkipped
-- testExplicitAcknowledgeCommitSuccess
-- testExplicitAcknowledgeReleaseAccept
-- testExplicitAcknowledgeReleaseClose
-- testExplicitAcknowledgeReleasePollAccept
-- testExplicitAcknowledgeSuccess
-- testExplicitAcknowledgeThrowsNotInBatch
-- testExplicitAcknowledgementCommitAsync
-- testExplicitAcknowledgementCommitAsyncPartialBatch
-- testFetchRecordLargerThanMaxPartitionFetchBytes
-- testHeaders
-- testHeadersSerializerDeserializer
-- testImplicitAcknowledgeCommitSync
-- testImplicitAcknowledgeFailsExplicit
-- testImplicitAcknowledgementCommitAsync
-- testLsoMovementByRecordsDeletion
-- testMaxPollRecords
-- testMultipleConsumersInGroupConcurrentConsumption
-- testMultipleConsumersInGroupFailureConcurrentConsumption
-- testMultipleConsumersInGroupSequentialConsumption
-- testMultipleConsumersInMultipleGroupsConcurrentConsumption
-- testMultipleConsumersWithDifferentGroupIds
-- testPollNoSubscribeFails
-- testPollThrowsInterruptExceptionIfInterrupted
-- testShareAutoOffsetResetByDuration
-- testShareAutoOffsetResetByDurationInvalidFormat
-- testShareAutoOffsetResetDefaultValue
-- testShareAutoOffsetResetEarliest
-- testShareAutoOffsetResetEarliestAfterLsoMovement
-- testShareAutoOffsetResetMultipleGroupsWithDifferentValue
-- testSubscribeAndPollNoRecords
-- testSubscribeOnInvalidTopicThrowsInvalidTopicException
-- testSubscribePollSubscribe
-- testSubscribePollUnsubscribe
-- testSubscribeSubscribeEmptyPollFails
-- testSubscribeUnsubscribePollFails
-- testSubscriptionAndPoll
-- testSubscriptionAndPollFollowedByTopicDeletion
-- testSubscriptionAndPollMultiple
-- testSubscriptionFollowedByTopicCreation
-- testWakeupWithFetchedRecordsAvailable
-kafka.tools.DumpLogSegmentsTest:
-- testBatchAndRecordMetadataOutput
-- testDumpEmptyIndex
-- testDumpIndexMismatches
-- testDumpMetadataRecords
-- testDumpMetadataSnapshot
-- testDumpRemoteLogMetadataEmpty
-- testDumpRemoteLogMetadataIoException
-- testDumpRemoteLogMetadataMultipleRecordsMultipleBatches
-- testDumpRemoteLogMetadataMultipleRecordsOneBatch
-- testDumpRemoteLogMetadataNoFilesFlag
-- testDumpRemoteLogMetadataNoSuchFileException
-- testDumpRemoteLogMetadataNonZeroStartingOffset
-- testDumpRemoteLogMetadataOneRecordOneBatch
-- testDumpRemoteLogMetadataWithCorruption
-- testDumpTimeIndexErrors
-- testOffsetsMessageParser
-- testPrintDataLog
-- testPrintDataLogPartialBatches
-- testShareGroupStateMessageParser
-kafka.tools.StorageToolTest:
-- testBootstrapScramRecords
-- testConfigToLogDirectories
-- testConfigToLogDirectoriesWithMetaLogDir
-- testFormatFailsIfAllDirectoriesAreUnavailable
-- testFormatFailsInZkMode
-- testFormatFailsOnAlreadyFormatted
-- testFormatSucceedsIfAllDirectoriesAreAvailable
-- testFormatSucceedsIfAtLeastOneDirectoryIsAvailable
-- testFormatWithInitialControllersFlag
-- testFormatWithInvalidFeature
-- testFormatWithInvalidKRaftVersionLevel
-- testFormatWithNoInitialControllersFlagAndInitialControllersFlagFails
-- testFormatWithNoInitialControllersFlagAndStandaloneFlagFails
-- testFormatWithNoInitialControllersSucceedsOnController
-- testFormatWithReleaseVersion
-- testFormatWithReleaseVersionAndKRaftVersion
-- testFormatWithReleaseVersionAsFeature
-- testFormatWithReleaseVersionDefault
-- testFormatWithReleaseVersionDefaultAndReleaseVersion
-- testFormatWithStandaloneFlag
-- testFormatWithStandaloneFlagAndInitialControllersFlagFails
-- testFormatWithStandaloneFlagOnBrokerFails
-- testFormatWithoutStaticQuorumFailsWithoutInitialControllersOnController
-- testFormatWithoutStaticQuorumSucceedsWithoutInitialControllersOnBroker
-- testHandleFeatureDependenciesForFeatureWithNoDependencies
-- testHandleFeatureDependenciesForFeatureWithUnknownFeatureVersion
-- testHandleFeatureDependenciesForInvalidVersionFormat
-- testHandleFeatureDependenciesForUnknownFeature
-- testIgnoreFormatted
-- testInfoCommandOnDirectoryAsFile
-- testInfoCommandOnEmptyDirectory
-- testInfoCommandOnMissingDirectory
-- testInfoWithMismatchedKRaftConfig
-- testInfoWithMismatchedLegacyKafkaConfig
-- testMultipleFeatureDependencies
-- testParseNameAndLevel
-- testParseNameAndLevelWithNoEquals
-- testParseNameAndLevelWithNoNumber
-- testScramRecordsOldReleaseVersion
-- testTestingFeatureDependencies
-- testVersionMappingWithInvalidReleaseVersion
-- testVersionMappingWithNoReleaseVersion
-- testVersionMappingWithValidReleaseVersion
-kafka.utils.CoreUtilsTest:
-- testAbs
-- testGenerateUuidAsBase64
-- testInLock
-- testReadBytes
-- testSwallow
-- testUrlSafeBase64EncodeUUID
-kafka.utils.JsonTest:
-- testEncodeAsBytes
-- testEncodeAsString
-- testJsonParse
-- testParseTo
-- testParseToWithInvalidJson
-kafka.utils.LoggingTest:
-- testLog4jControllerIsRegistered
-- testLogName
-- testLogNameOverride
-- testLoggerLevelIsResolved
-- testTypeOfGetLoggers
-kafka.utils.PoolTest:
-- testRemoveAll
-kafka.utils.SchedulerTest:
-- testMockSchedulerLocking
-- testMockSchedulerNonPeriodicTask
-- testMockSchedulerPeriodicTask
-- testNonPeriodicTask
-- testNonPeriodicTaskWhenPeriodIsZero
-- testPeriodicTask
-- testReentrantTaskInMockScheduler
-- testRestart
-- testUnscheduleProducerTask
-kafka.utils.json.JsonValueTest:
-- testAsJsonArray
-- testAsJsonArrayOption
-- testAsJsonObject
-- testAsJsonObjectOption
-- testDecodeBoolean
-- testDecodeDouble
-- testDecodeInt
-- testDecodeLong
-- testDecodeMap
-- testDecodeOption
-- testDecodeSeq
-- testDecodeString
-- testJsonArrayIterator
-- testJsonObjectApply
-- testJsonObjectGet
-- testJsonObjectIterator
-- testJsonValueEquals
-- testJsonValueHashCode
-- testJsonValueToString
-unit.kafka.server.AllocateProducerIdsRequestTest:
-- testAllocateProducersIdSentToController
-- testAllocateProducersIdSentToNonController
-unit.kafka.server.ForwardingManagerMetricsTest:
-- testMetricsNames
-- testQueueLength
-- testQueueTimeMs
-- testRemoteTimeMs
-- testTimeoutMs