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 b38c46b0c4a Update test catalog data for GHA workflow run 12190415330
b38c46b0c4a is described below
commit b38c46b0c4a7ee500887a1763915d083c54e5682
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Dec 6 02:33:44 2024 +0000
Update test catalog data for GHA workflow run 12190415330
Commit:
https://github.com/apache/kafka/commit/0ff55c316aab9b54adcb1cfc4d3d3dbedc279270
GitHub Run: https://github.com/apache/kafka/actions/runs/12190415330
---
test-catalog/clients/tests.yaml | 10 -
test-catalog/metadata/tests.yaml | 3 +-
test-catalog/tools/tests.yaml | 668 +++++++++++++++++++++++++++++++++++++++
3 files changed, 670 insertions(+), 11 deletions(-)
diff --git a/test-catalog/clients/tests.yaml b/test-catalog/clients/tests.yaml
index e68a98e8c4e..43e072047bf 100644
--- a/test-catalog/clients/tests.yaml
+++ b/test-catalog/clients/tests.yaml
@@ -618,7 +618,6 @@ org.apache.kafka.clients.consumer.ConsumerConfigTest:
- testProtocolConfigValidation
- testRemoteAssignorConfig
- testRemoteAssignorWithClassicGroupProtocol
-- testUnsupportedConfigsWithConsumerGroupProtocol
org.apache.kafka.clients.consumer.ConsumerGroupMetadataTest:
- testAssignmentConstructor
- testGroupIdConstructor
@@ -782,7 +781,6 @@ org.apache.kafka.clients.consumer.KafkaConsumerTest:
- testRegexSubscription
- testResetToCommittedOffset
- testResetUsingAutoResetPolicy
-- testResetUsingDurationBasedAutoResetPolicy
- testReturnRecordsDuringRebalance
- testSecondPollWithDeserializationErrorThrowsRecordDeserializationException
- testSeekNegative
@@ -821,7 +819,6 @@ org.apache.kafka.clients.consumer.MockConsumerTest:
- endOffsetsShouldBeIdempotent
- shouldNotClearRecordsForPausedPartitions
- testConsumerRecordsIsEmptyWhenReturningNoRecords
-- testDurationBasedOffsetReset
- testRe2JPatternSubscription
- testRebalanceListener
- testSimpleMock
@@ -1073,7 +1070,6 @@
org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumerTest:
- testSeekToEnd
- testSeekToEndWithException
- testSubscribeGeneratesEvent
-- testSubscribePatternAgainstBrokerNotSupportingRegex
- testSubscribePatternGeneratesEvent
- testSubscribeToEmptyListActsAsUnsubscribe
- testSubscribeToNullTopicCollection
@@ -1096,7 +1092,6 @@
org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumerTest:
org.apache.kafka.clients.consumer.internals.AutoOffsetResetStrategyTest:
- testEqualsAndHashCode
- testFromString
-- testTimestamp
- testValidator
org.apache.kafka.clients.consumer.internals.CommitRequestManagerTest:
- testAsyncAutocommitNotRetriedAfterException
@@ -1176,7 +1171,6 @@
org.apache.kafka.clients.consumer.internals.ConsumerHeartbeatRequestManagerTest:
- testSkippingHeartbeat
- testSuccessfulHeartbeatTiming
- testTimerNotDue
-- testUnsupportedVersion
- testValidateConsumerGroupHeartbeatRequest
- testValidateConsumerGroupHeartbeatRequestAssignmentSentWhenLocalEpochChanges
- testisExpiredByUsedForLogging
@@ -1912,7 +1906,6 @@
org.apache.kafka.clients.consumer.internals.OffsetFetcherTest:
- testUpdateFetchPositionOfPausedPartitionsWithAValidPosition
- testUpdateFetchPositionOfPausedPartitionsWithoutAValidPosition
- testUpdateFetchPositionResetToDefaultOffset
-- testUpdateFetchPositionResetToDurationOffset
- testUpdateFetchPositionResetToEarliestOffset
- testUpdateFetchPositionResetToLatestOffset
- testresetPositionsMetadataRefresh
@@ -2014,7 +2007,6 @@
org.apache.kafka.clients.consumer.internals.ShareConsumeRequestManagerTest:
- testPiggybackAcknowledgementsInFlight
- testRetryAcknowledgements
- testRetryAcknowledgementsWithLeaderChange
-- testServerDisconnectedOnShareAcknowledge
- testShareFetchWithSubscriptionChange
- testUnauthorizedTopic
- testUnknownTopicIdError
@@ -2266,7 +2258,6 @@
org.apache.kafka.clients.consumer.internals.events.ApplicationEventProcessorTest
- testSyncCommitEventWithoutCommitRequestManager
- testTopicPatternSubscriptionChangeEvent
- testTopicPatternSubscriptionChangeEventWithIllegalSubscriptionState
-- testTopicPatternSubscriptionTriggersJoin
- testTopicSubscriptionChangeEvent
- testTopicSubscriptionChangeEventWithIllegalSubscriptionState
- testUpdatePatternSubscriptionEventOnlyTakesEffectWhenMetadataHasNewVersion
@@ -3993,7 +3984,6 @@
org.apache.kafka.common.requests.TxnOffsetCommitRequestTest:
- testConstructor
- testGetErrorResponse
- testVersionSupportForGroupInstanceId
-- testVersionSupportForGroupMetadata
org.apache.kafka.common.requests.TxnOffsetCommitResponseTest:
- testConstructorWithErrorResponse
- testParse
diff --git a/test-catalog/metadata/tests.yaml b/test-catalog/metadata/tests.yaml
index 961ff420b51..2e0742f9344 100644
--- a/test-catalog/metadata/tests.yaml
+++ b/test-catalog/metadata/tests.yaml
@@ -215,7 +215,8 @@ org.apache.kafka.controller.QuorumControllerTest:
- testRegisterBrokerKRaftVersions
- testSnapshotSaveAndLoad
- testTimeouts
-- testUncleanShutdownBroker
+- testUncleanShutdownBrokerElrEnabled
+- testUncleanShutdownElrDisabled
- testUnregisterBroker
- testUpgradeFromPreProductionVersion
org.apache.kafka.controller.QuorumFeaturesTest:
diff --git a/test-catalog/tools/tests.yaml b/test-catalog/tools/tests.yaml
index 311cb1031fd..9cecc3f4708 100644
--- a/test-catalog/tools/tests.yaml
+++ b/test-catalog/tools/tests.yaml
@@ -1,3 +1,671 @@
+org.apache.kafka.tools.BrokerApiVersionsCommandTest:
+- testAdminSendNoBlock
+- testBrokerApiVersionsCommandOutput
+org.apache.kafka.tools.ClientMetricsCommandTest:
+- testAlter
+- testAlterGenerateName
+- testDelete
+- testDescribe
+- testDescribeAll
+- testList
+- testListFailsWithUnsupportedVersionException
+- testOptionsAlterAllOptionsSucceeds
+- testOptionsAlterGenerateNameSucceeds
+- testOptionsAlterNoNameFails
+- testOptionsAlterWithNameSucceeds
+- testOptionsDeleteNoNameFails
+- testOptionsDeleteWithNameSucceeds
+- testOptionsDescribeNoNameSucceeds
+- testOptionsDescribeWithNameSucceeds
+- testOptionsListSucceeds
+- testOptionsNoActionFails
+org.apache.kafka.tools.ClusterToolTest:
+- testClusterId
+- testClusterIdWithBootstrapController
+- testClusterTooOldToHaveId
+- testLegacyModeClusterCannotUnregisterBroker
+- testPrintClusterId
+- testUnregister
+- testUnregisterBroker
+- testUnregisterWithBootstrapController
+org.apache.kafka.tools.ConnectPluginPathTest:
+- testListMultipleLocations
+- testListMultiplePluginPaths
+- testListMultipleWorkerConfigs
+- testListNoArguments
+- testListOneLocation
+- testListOnePluginPath
+- testListOneWorkerConfig
+- testNoArguments
+- testSyncManifests
+- testSyncManifestsDryRun
+- testSyncManifestsDryRunReadOnlyLocation
+- testSyncManifestsDryRunReadOnlyManifest
+- testSyncManifestsDryRunReadOnlyMetaInf
+- testSyncManifestsDryRunReadOnlyServices
+- testSyncManifestsKeepNotFound
+org.apache.kafka.tools.ConsoleProducerTest:
+- testBatchSizeNotSetAndMaxPartitionMemoryBytesSet
+- testBatchSizeOverriddenByMaxPartitionMemoryBytesValue
+- testBatchSizeSetAndMaxPartitionMemoryBytesNotSet
+- testBootstrapServerOverride
+- testClientIdOverride
+- testDefaultBatchSize
+- testDefaultClientId
+- testInvalidConfigs
+- testLoopReader
+- testNewReader
+- testParseKeyProp
+- testParseReaderConfigFile
+- testValidConfigsBootstrapServer
+org.apache.kafka.tools.ConsumerPerformanceTest:
+- testClientIdOverride
+- testConfigBootStrapServer
+- testConfigWithUnrecognizedOption
+- testDefaultClientId
+- testDetailedHeaderMatchBody
+- testNonDetailedHeaderMatchBody
+org.apache.kafka.tools.DelegationTokenCommandTest:
+- testDelegationTokenRequests
+org.apache.kafka.tools.DeleteRecordsCommandTest:
+- testCommand
+- testCommandConfigNotExists
+- testOffsetFileNotExists
+- testParse
+- testWrongPartitions
+- testWrongVersion
+org.apache.kafka.tools.EndToEndLatencyTest:
+- shouldFailWhenConsumerRecordsIsEmpty
+- shouldFailWhenProducerAcksAreNotSynchronised
+- shouldFailWhenReceivedMoreThanOneRecord
+- shouldFailWhenSentIsNotEqualToReceived
+- shouldFailWhenSuppliedUnexpectedArgs
+- shouldPassInValidation
+org.apache.kafka.tools.FeatureCommandTest:
+- testDescribeWithKRaft
+- testDescribeWithKRaftAndBootstrapControllers
+- testDowngradeMetadataVersionWithKRaft
+- testDowngradeType
+- testDowngradeWithReleaseVersion
+- testHandleDescribe
+- testHandleDisable
+- testHandleDisableDryRun
+- testHandleDowngrade
+- testHandleDowngradeDryRun
+- testHandleFeatureDependenciesForFeatureWithDependencies
+- testHandleFeatureDependenciesForFeatureWithNoDependencies
+- testHandleFeatureDependenciesForFeatureWithUnknownFeatureVersion
+- testHandleFeatureDependenciesForInvalidVersionFormat
+- testHandleFeatureDependenciesForMultipleFeatures
+- testHandleFeatureDependenciesForUnknownFeature
+- testHandleUpgrade
+- testHandleUpgradeDryRun
+- testHandleVersionMappingWithInvalidReleaseVersion
+- testHandleVersionMappingWithNoReleaseVersion
+- testHandleVersionMappingWithValidReleaseVersion
+- testIncompatibleUpgradeFlags
+- testInvalidReleaseVersion
+- testLevelToString
+- testMetadataVersionsToString
+- testParseNameAndLevel
+- testUpgradeMetadataVersionWithKraft
+- testUpgradeWithReleaseVersion
+org.apache.kafka.tools.GetOffsetShellParsingTest:
+- testInvalidOffset
+- testInvalidTimeValue
+- testPartitionFilterForLowerBound
+- testPartitionFilterForRange
+- testPartitionFilterForSingleIndex
+- testPartitionFilterForUpperBound
+- testPartitionsSetFilter
+- testTopicPartitionFilterComplex
+- testTopicPartitionFilterForInternalTopicName
+- testTopicPartitionFilterForPartitionIndexSpec
+- testTopicPartitionFilterForPartitionLowerBoundSpec
+- testTopicPartitionFilterForPartitionRangeSpec
+- testTopicPartitionFilterForPartitionUpperBoundSpec
+- testTopicPartitionFilterForRegex
+- testTopicPartitionFilterForTopicName
+- testTopicPartitionFilterForTopicNameList
+org.apache.kafka.tools.GetOffsetShellTest:
+- testGetEarliestOffsets
+- testGetLatestOffsets
+- testGetOffsetsByEarliestLocalSpec
+- testGetOffsetsByLatestTieredSpec
+- testGetOffsetsByMaxTimestamp
+- testGetOffsetsByTimestamp
+- testInternalExcluded
+- testNoFilterOptions
+- testNoOffsetIfTimestampGreaterThanLatestRecord
+- testPartitionsArg
+- testPrintHelp
+- testPrintVersion
+- testTopicNameArg
+- testTopicPartitionsArg
+- testTopicPartitionsArgWithInternalExcluded
+- testTopicPartitionsArgWithInternalIncluded
+- testTopicPartitionsFlagWithPartitionsFlagCauseExit
+- testTopicPartitionsFlagWithTopicFlagCauseExit
+- testTopicPartitionsNotFoundForExcludedInternalTopic
+- testTopicPartitionsNotFoundForNonExistentTopic
+- testTopicPartitionsNotFoundForNonMatchingTopicPartitionPattern
+- testTopicPatternArg
+- testTopicPatternArgWithPartitionsArg
+org.apache.kafka.tools.GroupsCommandTest:
+- testGroupCommand
+- testListGroups
+- testListGroupsConsumerFilter
+- testListGroupsEmpty
+- testListGroupsFailsWithException
+- testListGroupsProtocolAndTypeFilter
+- testListGroupsProtocolAndTypeFilterNoMatch
+- testListGroupsProtocolFilter
+- testListGroupsShareFilter
+- testListGroupsTypeFilter
+- testOptionsListConsumerAndProtocolFilterFails
+- testOptionsListConsumerAndShareFilterFails
+- testOptionsListConsumerAndTypeFilterFails
+- testOptionsListConsumerFilterSucceeds
+- testOptionsListInvalidTypeFilterFails
+- testOptionsListProtocolAndTypeFiltersSucceeds
+- testOptionsListProtocolFilterSucceeds
+- testOptionsListShareAndProtocolFilterFails
+- testOptionsListShareAndTypeFilterFails
+- testOptionsListShareFilterSucceeds
+- testOptionsListSucceeds
+- testOptionsListTypeFilterSucceeds
+- testOptionsNoActionFails
+org.apache.kafka.tools.JmxToolTest:
+- allMetrics
+- csvFormat
+- dateFormat
+- filteredMetrics
+- helpOptions
+- kafkaVersion
+- malformedURL
+- missingRequired
+- testDomainNamePattern
+- testDomainNamePatternWithNoAttributes
+- testPropertyListPattern
+- testPropertyListPatternWithNoAttributes
+- testPropertyPattern
+- testPropertyPatternWithNoAttributes
+- testPropertyValuePattern
+- testPropertyValuePatternWithNoAttributes
+- tsvFormat
+- unknownObjectName
+- unrecognizedOption
+org.apache.kafka.tools.LeaderElectionCommandErrorTest:
+- testInvalidBroker
+- testMissingElectionType
+- testMissingTopicPartitionSelection
+- testPartitionWithoutTopic
+- testTopicWithoutPartition
+org.apache.kafka.tools.LeaderElectionCommandTest:
+- testAdminConfigCustomTimeouts
+- testAllTopicPartition
+- testElectionResultOutput
+- testPathToJsonFile
+- testPreferredReplicaElection
+- testTopicDoesNotExist
+- testTopicPartition
+org.apache.kafka.tools.LineMessageReaderTest:
+- testDemarcationsLongerThanOne
+- testHeaderDemarcationCollision
+- testIgnoreErrorInInput
+- testInvalidNullMarker
+- testKeyMissingValue
+- testLineReader
+- testLineReaderHeader
+- testLineReaderHeaderNoKey
+- testLineReaderOnlyValue
+- testMalformedHeaderIgnoreError
+- testMinimalValidInputWithHeaderKeyAndValue
+- testMissingHeaderKeySeparator
+- testMissingKeySeparator
+- testNullMarker
+- testNullMarkerHeaderKeyThrows
+- testNullMarkerWithHeaders
+-
testParseHeaderEnabledWithCustomDelimiterAndVaryingNumberOfKeyValueHeaderPairs
+org.apache.kafka.tools.LogDirsCommandTest:
+- shouldNotThrowWhenDuplicatedBrokers
+- shouldQueryAllBrokersIfNonSpecified
+- shouldQuerySpecifiedBroker
+- shouldThrowWhenQueryingNonExistentBrokers
+- testLogDirsWithBrokers
+- testLogDirsWithNonExistentTopic
+- testLogDirsWithSpecificTopic
+- testLogDirsWithoutBrokers
+org.apache.kafka.tools.MetadataQuorumCommandErrorTest:
+- testDescribeOptions
+- testPropertiesFileDoesNotExists
+- testRelativeTimeMs
+- testRemoveControllerRequiresControllerDirectoryId
+- testRemoveControllerRequiresControllerId
+org.apache.kafka.tools.MetadataQuorumCommandTest:
+- testCommandConfig
+- testDescribeQuorumReplicationSuccessful
+- testDescribeQuorumStatusSuccessful
+- testHumanReadableOutput
+- testOnlyOneBrokerAndOneController
+org.apache.kafka.tools.MetadataQuorumCommandUnitTest:
+- testAddControllerDryRun
+- testGetControllerAdvertisedListenersWithNoControllerListenerInformation
+- testGetControllerAdvertisedListenersWithNoControllerListenerNames
+- testGetControllerAdvertisedListenersWithRegularListeners
+-
testGetControllerAdvertisedListenersWithRegularListenersAndAdvertisedListeners
+- testGetControllerId
+- testGetControllerIdWithBrokerProcessRoles
+- testGetControllerIdWithoutId
+- testGetControllerIdWithoutProcessRoles
+- testGetMetadataDirectory
+- testGetMetadataDirectoryFailure
+- testGetMetadataDirectoryFromLogDirs
+- testGetMetadataDirectoryFromMultipleLogDirs
+- testGetMetadataDirectoryId
+- testGetMetadataDirectoryIdWhenThereIsNoDirectory
+- testGetMetadataDirectoryIdWhenThereIsNoId
+- testGetNegativeControllerId
+- testRemoveControllerDryRun
+org.apache.kafka.tools.ProducerPerformanceTest:
+- testClientIdOverride
+- testConfigPostProcessor
+- testDefaultClientId
+- testEnableTransaction
+- testEnableTransactionByProducerProps
+- testEnableTransactionByTransactionDurationMs
+- testEnableTransactionByTransactionId
+- testFractionalThroughput
+- testGenerateMonotonicPayload
+- testGenerateRandomPayloadByPayloadFile
+- testGenerateRandomPayloadByRecordSize
+- testGenerateRandomPayloadException
+- testInvalidConfigPostProcessor
+- testMutuallyExclusiveGroup
+- testNoTransactionRelatedConfigs
+- testNumberOfCallsForSendAndClose
+- testNumberOfFailedSendAndClose
+- testNumberOfSuccessfulSendAndClose
+- testReadPayloadFile
+- testReadProps
+- testStatsCorrectness
+- testStatsInitializationWithLargeNumRecords
+- testUnexpectedArg
+org.apache.kafka.tools.PushHttpMetricsReporterTest:
+- testClientError
+- testConfigureBadUrl
+- testConfigureClose
+- testConfigureMissingPeriod
+- testMetricValues
+- testNoMetrics
+- testServerError
+org.apache.kafka.tools.ReplicaVerificationToolTest:
+- testReplicaBufferVerifyChecksum
+org.apache.kafka.tools.ResetIntegrationTest:
+- shouldNotAllowToResetWhenInputTopicAbsent
+- shouldNotAllowToResetWhenIntermediateTopicAbsent
+- shouldNotAllowToResetWhenSpecifiedInternalTopicDoesNotExist
+- shouldNotAllowToResetWhenSpecifiedInternalTopicIsNotInternal
+- shouldNotAllowToResetWhileStreamsIsRunning
+- testReprocessingByDurationAfterResetWithoutIntermediateUserTopic
+- testReprocessingFromDateTimeAfterResetWithoutIntermediateUserTopic
+- testReprocessingFromFileAfterResetWithoutIntermediateUserTopic
+- testReprocessingFromScratchAfterResetWithIntermediateInternalTopic
+- testReprocessingFromScratchAfterResetWithIntermediateUserTopic
+- testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
+- testResetWhenInternalTopicsAreSpecified
+- testResetWhenLongSessionTimeoutConfiguredWithForceOption
+org.apache.kafka.tools.ResetIntegrationWithSslTest:
+- testReprocessingFromScratchAfterResetWithIntermediateInternalTopic
+- testReprocessingFromScratchAfterResetWithIntermediateUserTopic
+- testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
+- testResetWhenInternalTopicsAreSpecified
+org.apache.kafka.tools.StreamsResetterTest:
+- shouldDeleteTopic
+- shouldDetermineInternalTopicBasedOnTopicName1
+- shouldSeekToEndOffset
+- testResetOffsetToSpecificOffsetWhenAfterEndOffset
+- testResetToDatetimeWhenPartitionIsEmptyResetsToLatestOffset
+- testResetToSpecificOffsetWhenAfterEndOffset
+- testResetToSpecificOffsetWhenBeforeBeginningOffset
+- testResetToSpecificOffsetWhenBetweenBeginningAndEndOffset
+- testResetUsingPlanWhenAfterEndOffset
+- testResetUsingPlanWhenBeforeBeginningOffset
+- testResetUsingPlanWhenBetweenBeginningAndEndOffset
+- testShiftOffsetByWhenAfterEndOffset
+- testShiftOffsetByWhenBeforeBeginningOffset
+- testShiftOffsetByWhenBetweenBeginningAndEndOffset
+org.apache.kafka.tools.TopicCommandTest:
+- testAlterAssignment
+- testAlterAssignmentWithMoreAssignmentThanPartitions
+- testAlterAssignmentWithMorePartitionsThanAssignment
+- testAlterPartitionCount
+- testAlterWhenTopicDoesntExist
+- testAlterWhenTopicDoesntExistWithIfExists
+- testAlterWithInvalidPartitionCount
+- testAlterWithUnspecifiedPartitionCount
+- testConfigOptWithBootstrapServers
+- testConfigPreservationAcrossPartitionAlteration
+- testCreate
+- testCreateAlterTopicWithRackAware
+- testCreatePartitionsDoesNotRetryThrottlingQuotaExceededException
+- testCreateTopicDoesNotRetryThrottlingQuotaExceededException
+- testCreateWhenAlreadyExists
+- testCreateWhenAlreadyExistsWithIfNotExists
+- testCreateWithAssignmentAndPartitionCount
+- testCreateWithAssignmentAndReplicationFactor
+- testCreateWithConfigs
+- testCreateWithDefaultPartitions
+- testCreateWithDefaultReplication
+- testCreateWithDefaults
+- testCreateWithInvalidReplicationFactor
+- testCreateWithNegativePartitionCount
+- testCreateWithNegativeReplicationFactor
+- testCreateWithPartitionCountWithoutReplicationFactorShouldSucceed
+- testCreateWithReplicaAssignment
+- testCreateWithReplicationFactorWithoutPartitionCountShouldSucceed
+- testCreateWithTopicNameCollision
+- testCreateWithoutPartitionCountAndReplicationFactorShouldSucceed
+- testDeleteInternalTopic
+- testDeleteTopicDoesNotRetryThrottlingQuotaExceededException
+- testDeleteWhenTopicDoesntExist
+- testDeleteWhenTopicDoesntExistWithIfExists
+- testDescribe
+- testDescribeAndListTopicsWithoutInternalTopics
+- testDescribeAtMinIsrPartitions
+- testDescribeDoesNotFailWhenListingReassignmentIsUnauthorized
+- testDescribeReportOverriddenConfigs
+- testDescribeShouldSucceed
+- testDescribeUnavailablePartitions
+- testDescribeUnderMinIsrPartitions
+- testDescribeUnderMinIsrPartitionsMixed
+- testDescribeUnderReplicatedPartitions
+- testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress
+- testDescribeWhenTopicDoesntExist
+- testDescribeWhenTopicDoesntExistWithIfExists
+- testDescribeWithDescribeTopicPartitionsApi
+- testDescribeWithDescribeTopicsApiShouldSucceed
+- testInvalidTopicLevelConfig
+- testIsNotUnderReplicatedWhenAdding
+- testListTopics
+- testListTopicsWithExcludeInternal
+- testListTopicsWithIncludeList
+- testParseAssignment
+- testParseAssignmentDuplicateEntries
+- testParseAssignmentPartitionsOfDifferentSize
+- testTopicDeletion
+- testTopicWithCollidingCharDeletionAndCreateAgain
+org.apache.kafka.tools.TransactionsCommandTest:
+- testDescribeProducersLeader
+- testDescribeProducersPartitionRequired
+- testDescribeProducersSpecificReplica
+- testDescribeProducersTopicRequired
+- testDescribeTransaction
+- testDescribeTransactionsCoordinatorEpochRequiredWithProducerId
+- testDescribeTransactionsPartitionRequired
+- testDescribeTransactionsProducerEpochRequiredWithProducerId
+- testDescribeTransactionsStartOffsetOrProducerIdRequired
+- testDescribeTransactionsTopicRequired
+- testDescribeTransactionsTransactionalIdRequired
+- testFindHangingDoesNotFilterByTransactionInProgressWithDifferentPartitions
+- testFindHangingFilterByTransactionInProgressWithSamePartition
+- testFindHangingLookupTopicAndBrokerId
+- testFindHangingLookupTopicPartitionsForBroker
+- testFindHangingLookupTopicPartitionsForTopic
+- testFindHangingNoMappedTransactionalId
+- testFindHangingRequiresEitherBrokerIdOrTopic
+- testFindHangingRequiresTopicIfPartitionIsSpecified
+- testFindHangingSpecifiedTopicPartition
+- testFindHangingWithNoTransactionDescription
+- testListTransactions
+- testNewBrokerAbortTransaction
+- testOldBrokerAbortTransactionWithUnknownCoordinatorEpoch
+org.apache.kafka.tools.consumer.ConsoleConsumerOptionsTest:
+- groupIdsProvidedInDifferentPlacesMustMatch
+- shouldExitIfFromBeginningAndOffset
+- shouldExitIfNoTopicOrFilterSpecified
+- shouldExitIfPartitionButNoTopic
+- shouldExitIfTopicAndIncludeSpecified
+- shouldExitOnGroupIdAndPartitionGivenTogether
+- shouldExitOnInvalidConfigWithAutoOffsetResetAndConflictingFromBeginning
+- shouldExitOnOffsetWithoutPartition
+- shouldExitOnUnrecognizedNewConsumerOption
+- shouldParseConfigsFromFile
+- shouldParseGroupIdFromBeginningGivenTogether
+- shouldParseIncludeArgument
+- shouldParseValidConsumerConfigWithAutoOffsetResetAndMatchingFromBeginning
+- shouldParseValidConsumerConfigWithAutoOffsetResetEarliest
+- shouldParseValidConsumerConfigWithAutoOffsetResetLatest
+- shouldParseValidConsumerConfigWithNoOffsetReset
+- shouldParseValidConsumerValidConfig
+- shouldParseValidSimpleConsumerValidConfigWithNumericOffset
+- shouldParseValidSimpleConsumerValidConfigWithStringOffset
+- testClientIdOverride
+- testCustomConfigShouldBePassedToConfigureMethod
+- testCustomPropertyShouldBePassedToConfigureMethod
+- testDefaultClientId
+- testParseFormatter
+- testParseOffset
+- testParseTimeoutMs
+org.apache.kafka.tools.consumer.ConsoleConsumerTest:
+- shouldLimitReadsToMaxMessageLimit
+- shouldResetUnConsumedOffsetsBeforeExit
+- shouldSeekWhenOffsetIsSet
+- shouldStopWhenOutputCheckErrorFails
+- shouldThrowTimeoutExceptionWhenTimeoutIsReached
+- shouldWorkWithoutTopicOption
+- testGroupMetadataMessageFormatter
+- testOffsetsMessageFormatter
+- testTransactionLogMessageFormatter
+org.apache.kafka.tools.consumer.ConsoleShareConsumerOptionsTest:
+- groupIdsProvidedInDifferentPlacesMustMatch
+- shouldExitIfNoTopicSpecified
+- shouldExitOnUnrecognizedNewConsumerOption
+- shouldParseConfigsFromFile
+- shouldParseValidConsumerConfigWithSessionTimeout
+- shouldParseValidConsumerValidConfig
+- testClientIdOverride
+- testDefaultClientId
+- testRejectAndReleaseOption
+- testRejectOption
+- testReleaseOption
+org.apache.kafka.tools.consumer.ConsoleShareConsumerTest:
+- shouldLimitReadsToMaxMessageLimit
+- shouldStopWhenOutputCheckErrorFails
+- shouldThrowTimeoutExceptionWhenTimeoutIsReached
+- testRejectMessageOnError
+org.apache.kafka.tools.consumer.DefaultMessageFormatterTest:
+- testDefaultMessageFormatter
+org.apache.kafka.tools.consumer.GroupMetadataMessageFormatterTest:
+- testTransactionLogMessageFormatter
+org.apache.kafka.tools.consumer.NoOpMessageFormatterTest:
+- testNoOpMessageFormatter
+org.apache.kafka.tools.consumer.OffsetMessageFormatterTest:
+- testTransactionLogMessageFormatter
+org.apache.kafka.tools.consumer.TransactionLogMessageFormatterTest:
+- testTransactionLogMessageFormatter
+org.apache.kafka.tools.consumer.group.AuthorizerIntegrationTest:
+- testDescribeGroupCliWithGroupDescribe
org.apache.kafka.tools.consumer.group.ConsumerGroupCommandTest:
- testValidateRegexCommandWithInvalidRegex
- testValidateRegexCommandWithValidRegex
+org.apache.kafka.tools.consumer.group.ConsumerGroupServiceTest:
+- testAdminRequestsForDescribeNegativeOffsets
+- testAdminRequestsForDescribeOffsets
+- testAdminRequestsForResetOffsets
+org.apache.kafka.tools.consumer.group.DeleteConsumerGroupsTest:
+- testDeleteCmdAllGroups
+- testDeleteCmdNonExistingGroup
+- testDeleteCmdWithMixOfSuccessAndError
+- testDeleteEmptyGroup
+- testDeleteNonEmptyGroup
+- testDeleteNonExistingGroup
+- testDeleteWithMixOfSuccessAndError
+- testDeleteWithTopicOption
+- testDeleteWithUnrecognizedNewConsumerOption
+org.apache.kafka.tools.consumer.group.DeleteOffsetsConsumerGroupCommandIntegrationTest:
+- testDeleteOffsetsNonExistingGroup
+- testDeleteOffsetsOfEmptyConsumerGroupWithTopicOnly
+- testDeleteOffsetsOfEmptyConsumerGroupWithTopicPartition
+- testDeleteOffsetsOfEmptyConsumerGroupWithUnknownTopicOnly
+- testDeleteOffsetsOfEmptyConsumerGroupWithUnknownTopicPartition
+- testDeleteOffsetsOfStableConsumerGroupWithTopicOnly
+- testDeleteOffsetsOfStableConsumerGroupWithTopicPartition
+- testDeleteOffsetsOfStableConsumerGroupWithUnknownTopicOnly
+- testDeleteOffsetsOfStableConsumerGroupWithUnknownTopicPartition
+org.apache.kafka.tools.consumer.group.DescribeConsumerGroupTest:
+- testDescribeAllExistingGroups
+- testDescribeExistingGroup
+- testDescribeExistingGroupWithNoMembers
+- testDescribeExistingGroups
+- testDescribeGroupMembersWithShortInitializationTimeout
+- testDescribeGroupOffsetsWithShortInitializationTimeout
+- testDescribeGroupStateWithShortInitializationTimeout
+- testDescribeGroupWithShortInitializationTimeout
+- testDescribeMembersOfExistingGroup
+- testDescribeMembersOfExistingGroupWithNoMembers
+- testDescribeMembersOfNonExistingGroup
+- testDescribeMembersWithConsumersWithoutAssignedPartitions
+- testDescribeMembersWithMultiPartitionTopicAndMultipleConsumers
+- testDescribeNonExistingGroup
+- testDescribeNonOffsetCommitGroup
+- testDescribeOffsetsOfExistingGroup
+- testDescribeOffsetsOfExistingGroupWithNoMembers
+- testDescribeOffsetsOfNonExistingGroup
+- testDescribeOffsetsWithConsumersWithoutAssignedPartitions
+- testDescribeOffsetsWithMultiPartitionTopicAndMultipleConsumers
+- testDescribeSimpleConsumerGroup
+- testDescribeStateOfExistingGroup
+- testDescribeStateOfExistingGroupWithNoMembers
+- testDescribeStateOfExistingGroupWithNonDefaultAssignor
+- testDescribeStateOfNonExistingGroup
+- testDescribeStateWithConsumersWithoutAssignedPartitions
+- testDescribeStateWithMultiPartitionTopicAndMultipleConsumers
+- testDescribeWithConsumersWithoutAssignedPartitions
+- testDescribeWithMultiPartitionTopicAndMultipleConsumers
+- testDescribeWithMultipleSubActions
+- testDescribeWithStateValue
+- testDescribeWithUnrecognizedNewConsumerOption
+- testPrintVersion
+org.apache.kafka.tools.consumer.group.ListConsumerGroupTest:
+- testListConsumerGroupsWithStates
+- testListConsumerGroupsWithTypesClassicProtocol
+- testListConsumerGroupsWithTypesConsumerProtocol
+- testListConsumerGroupsWithoutFilters
+- testListGroupCommandClassicProtocol
+- testListGroupCommandConsumerProtocol
+- testListWithUnrecognizedNewConsumerOption
+org.apache.kafka.tools.consumer.group.ListConsumerGroupUnitTest:
+- testConsumerGroupStatesFromString
+- testConsumerGroupTypesFromString
+org.apache.kafka.tools.consumer.group.ResetConsumerGroupOffsetTest:
+- testResetOffsetsAllTopicsAllGroups
+- testResetOffsetsByDuration
+- testResetOffsetsByDurationFallbackToLatestWhenNoRecords
+- testResetOffsetsByDurationToEarliest
+- testResetOffsetsExistingTopic
+- testResetOffsetsExistingTopicAllGroups
+- testResetOffsetsExistingTopicSelectedGroups
+- testResetOffsetsExportImportPlan
+- testResetOffsetsExportImportPlanSingleGroupArg
+- testResetOffsetsNotExistingGroup
+- testResetOffsetsShiftByHigherThanLatest
+- testResetOffsetsShiftByLowerThanEarliest
+- testResetOffsetsShiftMinus
+- testResetOffsetsShiftPlus
+- testResetOffsetsToCurrentOffset
+- testResetOffsetsToEarliest
+- testResetOffsetsToEarliestOnOneTopic
+- testResetOffsetsToEarliestOnOneTopicAndPartition
+- testResetOffsetsToEarliestOnTopics
+- testResetOffsetsToEarliestOnTopicsAndPartitions
+- testResetOffsetsToLatest
+- testResetOffsetsToLocalDateTime
+- testResetOffsetsToSpecificOffset
+- testResetOffsetsToZonedDateTime
+- testResetWithUnrecognizedNewConsumerOption
+org.apache.kafka.tools.consumer.group.SaslClientsWithInvalidCredentialsTest:
+- testConsumerGroupServiceWithAuthenticationFailure
+- testConsumerGroupServiceWithAuthenticationSuccess
+org.apache.kafka.tools.consumer.group.ShareGroupCommandTest:
+- testDescribeShareGroups
+- testDescribeShareGroupsGetOffsets
+- testGroupStatesFromString
+- testListShareGroups
+- testListShareGroupsWithStates
+- testListWithUnrecognizedOption
+- testPrintEmptyGroupState
+org.apache.kafka.tools.consumer.group.share.ShareGroupStateMessageFormatterTest:
+- testShareGroupStateMessageFormatter
+- testShareGroupStateMessageFormatterException
+org.apache.kafka.tools.filter.TopicFilterTest:
+- testIncludeLists
+org.apache.kafka.tools.reassign.ReassignPartitionsCommandArgsTest:
+- shouldAllowBootstrapControllerArg
+- shouldAllowThrottleOptionOnExecute
+- shouldCorrectlyParseValidMinimumExecuteOptions
+- shouldCorrectlyParseValidMinimumGenerateOptions
+- shouldCorrectlyParseValidMinimumVerifyOptions
+- shouldFailIfBlankArg
+- shouldFailIfMultipleActions
+- shouldFailIfNoArgs
+- shouldNotAllowBootstrapControllerAndBootstrapServerArg
+- shouldNotAllowBootstrapControllerArgWithUnsupportedAction
+- shouldNotAllowBrokersListWithVerifyOption
+- shouldNotAllowCancelWithoutBootstrapServerOption
+- shouldNotAllowCancelWithoutReassignmentJsonFile
+- shouldNotAllowExecuteWithBrokerList
+- shouldNotAllowExecuteWithTopicsOption
+- shouldNotAllowExecuteWithoutReassignmentOption
+- shouldNotAllowGenerateWithReassignmentOption
+- shouldNotAllowGenerateWithThrottleOption
+- shouldNotAllowGenerateWithoutBrokersAndTopicsOptions
+- shouldNotAllowGenerateWithoutBrokersOption
+- shouldNotAllowGenerateWithoutTopicsOption
+- shouldNotAllowThrottleWithVerifyOption
+- shouldNotAllowTopicsOptionWithVerify
+- shouldNotAllowVerifyWithoutReassignmentOption
+- shouldPrintHelpTextIfHelpArg
+- shouldUseDefaultsIfEnabled
+- testCancelWithPreserveThrottlesOption
+- testList
+- testMissingBootstrapServerArgumentForExecute
+org.apache.kafka.tools.reassign.ReassignPartitionsCommandTest:
+- testAlterLogDirReassignmentThrottle
+- testAlterReassignmentThrottle
+- testCancellationWithAddingReplicaInIsr
+- testCancellationWithBootstrapController
+- testCancellationWithBootstrapServer
+- testGenerateAssignmentWithBootstrapServer
+- testHighWaterMarkAfterPartitionReassignment
+- testLogDirReassignment
+- testProduceAndConsumeWithReassignmentInProgress
+- testReassignment
+- testReassignmentCompletionDuringPartialUpgrade
+- testReassignmentWithAlterPartitionDisabled
+- testThrottledReassignment
+org.apache.kafka.tools.reassign.ReassignPartitionsUnitTest:
+- testAlterReplicaLogDirs
+- testCompareTopicPartitionReplicas
+- testCompareTopicPartitions
+- testCurReassignmentsToString
+- testCurrentPartitionReplicaAssignmentToString
+- testExecuteWithInvalidBrokerIdFails
+- testExecuteWithInvalidPartitionsFails
+- testFindLogDirMoveStates
+- testFindPartitionReassignmentStates
+- testGenerateAssignmentFailsWithoutEnoughReplicas
+- testGenerateAssignmentWithFewerBrokers
+- testGenerateAssignmentWithInconsistentRacks
+- testGenerateAssignmentWithInvalidPartitionsFails
+- testGetBrokerRackInformation
+- testGetReplicaAssignments
+- testModifyBrokerInterBrokerThrottle
+- testModifyLogDirThrottle
+- testModifyTopicThrottles
+- testMoveMap
+- testParseExecuteAssignmentArgs
+- testParseGenerateAssignmentArgs
+- testPartitionReassignStatesToString
+- testPropagateInvalidJsonError
+- testReplicaMoveStatesToString
