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 9dd0e468306 Update test catalog data for GHA workflow run 12251038908
9dd0e468306 is described below
commit 9dd0e46830614c2cb3a333f8b57d894b5ebf1e7b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Dec 10 09:21:23 2024 +0000
Update test catalog data for GHA workflow run 12251038908
Commit:
https://github.com/apache/kafka/commit/e5598a9d8c7ec134740af48911cc60e72bf638eb
GitHub Run: https://github.com/apache/kafka/actions/runs/12251038908
---
test-catalog/connect/mirror/tests.yaml | 249 ---------------
test-catalog/core/tests.yaml | 53 ----
test-catalog/raft/tests.yaml | 11 -
test-catalog/storage/tests.yaml | 44 ---
test-catalog/streams/integration-tests/tests.yaml | 360 ----------------------
test-catalog/tools/tests.yaml | 3 -
6 files changed, 720 deletions(-)
diff --git a/test-catalog/connect/mirror/tests.yaml
b/test-catalog/connect/mirror/tests.yaml
deleted file mode 100644
index 0bd453eca89..00000000000
--- a/test-catalog/connect/mirror/tests.yaml
+++ /dev/null
@@ -1,249 +0,0 @@
-org.apache.kafka.connect.mirror.CheckpointStoreTest:
-- testReadCheckpointsTopic
-- testReadCheckpointsTopicError
-org.apache.kafka.connect.mirror.CheckpointTest:
-- testSerde
-org.apache.kafka.connect.mirror.HeartbeatTest:
-- testSerde
-org.apache.kafka.connect.mirror.MirrorCheckpointConfigTest:
-- testConsumerConfigsForOffsetSyncsTopic
-- testGroupMatching
-- testNonMutationOfConfigDef
-- testSkipValidationIfConnectorDisabled
-- testTaskConfigConsumerGroups
-- testValidateIfConnectorEnabled
-org.apache.kafka.connect.mirror.MirrorCheckpointConnectorTest:
-- testAlterOffsetsIncorrectOffsetKey
-- testAlterOffsetsIncorrectPartitionKey
-- testAlterOffsetsInvalidPartitionPartition
-- testAlterOffsetsMissingPartitionKey
-- testAlterOffsetsMultiplePartitions
-- testAlterOffsetsOffsetValues
-- testAlterOffsetsTombstones
-- testConsumerGroupInitializeTimeout
-- testFindConsumerGroups
-- testFindConsumerGroupsInCommonScenarios
-- testMirrorCheckpointConnectorDisabled
-- testMirrorCheckpointConnectorEnabled
-- testNoConsumerGroup
-- testReplicationDisabled
-- testReplicationEnabled
-- testSuccessfulAlterOffsets
-org.apache.kafka.connect.mirror.MirrorCheckpointTaskTest:
-- testCheckpoint
-- testCheckpointRecordsMonotonicIfStoreRewinds
-- testCheckpointStoreInitialized
-- testCheckpointsTaskRestartUsesExistingCheckpoints
-- testDownstreamTopicRenaming
-- testNoCheckpointForTopicWithNullOffsetAndMetadata
-- testNoCheckpointForTopicWithoutOffsetSyncs
-- testSyncOffset
-- testSyncOffsetForTargetGroupWithNullOffsetAndMetadata
-org.apache.kafka.connect.mirror.MirrorConnectorConfigTest:
-- testCaseInsensitiveSecurityProtocol
-- testExplicitlyEnableJmxReporter
-- testInvalidSecurityProtocol
-- testMetricsReporters
-- testReplicationPolicy
-- testSourceAdminConfig
-- testSourceAdminConfigWithSourcePrefix
-- testSourceConsumerConfig
-- testSourceConsumerConfigWithSourcePrefix
-- testSourceProducerConfig
-- testSourceProducerConfigWithSourcePrefix
-- testTargetAdminConfig
-- testTargetAdminConfigWithSourcePrefix
-org.apache.kafka.connect.mirror.MirrorHeartBeatConnectorTest:
-- testAlterOffsetsIncorrectOffsetKey
-- testAlterOffsetsIncorrectPartitionKey
-- testAlterOffsetsMissingPartitionKey
-- testAlterOffsetsMultiplePartitions
-- testAlterOffsetsOffsetValues
-- testAlterOffsetsTombstones
-- testMirrorHeartbeatConnectorDisabled
-- testReplicationDisabled
-- testSuccessfulAlterOffsets
-org.apache.kafka.connect.mirror.MirrorHeartbeatTaskTest:
-- testPollCreatesRecords
-org.apache.kafka.connect.mirror.MirrorMakerConfigTest:
-- testAllConfigNames
-- testCaseInsensitiveSecurityProtocol
-- testClientConfigProperties
-- testClientInvalidSecurityProtocol
-- testClusterConfigProperties
-- testClusterPairsWithDefaultSettings
-- testClusterPairsWithGloballyDisabledHeartbeats
-- testClusterPairsWithGloballyDisabledHeartbeatsCentralLocal
-- testClusterPairsWithTwoDisabledHeartbeats
-- testEmptyClusterPairsWithGloballyDisabledHeartbeats
-- testIncludesConnectorConfigProperties
-- testIncludesTopicFilterProperties
-- testInvalidSecurityProtocol
-- testLazyConfigResolution
-- testReplicationConfigProperties
-- testWorkerConfigs
-org.apache.kafka.connect.mirror.MirrorSourceConfigTest:
-- testAdminConfigsForOffsetSyncsTopic
-- testAllTopics
-- testConfigPropertyMatching
-- testListOfTopics
-- testNoTopics
-- testNonMutationOfConfigDef
-- testOffsetSyncsTopic
-- testProducerConfigsForOffsetSyncsTopic
-- testTaskConfigTopicPartitions
-- testTopicMatching
-org.apache.kafka.connect.mirror.MirrorSourceConnectorTest:
-- testAclFiltering
-- testAclTransformation
-- testAlterOffsetsIncorrectOffsetKey
-- testAlterOffsetsIncorrectPartitionKey
-- testAlterOffsetsInvalidPartitionPartition
-- testAlterOffsetsMissingPartitionKey
-- testAlterOffsetsMultiplePartitions
-- testAlterOffsetsOffsetValues
-- testAlterOffsetsTombstones
-- testConfigPropertyFiltering
-- testConfigPropertyFilteringWithAlterConfigs
-- testConfigPropertyFilteringWithAlterConfigsAndSourceDefault
-- testDoesNotReplicateHeartbeatsWhenDisabled
-- testExactlyOnceSupport
-- testExactlyOnceSupportValidation
-- testIdentityReplication
-- testIsCycleWithNullUpstreamTopic
-- testMirrorSourceConnectorTaskConfig
-- testMissingDescribeConfigsAcl
-- testNewTopicConfigs
-- testNoBrokerAclAuthorizer
-- testNoCycles
-- testRefreshTopicPartitions
-- testRefreshTopicPartitionsTopicOnTargetFirst
-- testReplicatesHeartbeatsByDefault
-- testReplicatesHeartbeatsDespiteFilter
-- testReplicatesHeartbeatsWhenDisabledButFilterAllows
-- testSuccessfulAlterOffsets
-org.apache.kafka.connect.mirror.MirrorSourceMetricsTest:
-- testTags
-org.apache.kafka.connect.mirror.MirrorSourceTaskTest:
-- testCommitRecordWithNullMetadata
-- testOffsetSync
-- testPoll
-- testSeekBehaviorDuringStart
-- testSendSyncEvent
-- testSerde
-- testZeroOffsetSync
-org.apache.kafka.connect.mirror.MirrorUtilsTest:
-- testCreateCompactedTopic
-- testCreateCompactedTopicAlreadyExists
--
testCreateCompactedTopicAssumeTopicAlreadyExistsWithClusterAuthorizationException
--
testCreateCompactedTopicAssumeTopicAlreadyExistsWithTopicAuthorizationException
--
testCreateCompactedTopicAssumeTopicAlreadyExistsWithUnsupportedVersionException
-- testCreateCompactedTopicFailsWithInvalidConfigurationException
-- testCreateCompactedTopicFailsWithTimeoutException
-org.apache.kafka.connect.mirror.OffsetSyncStoreTest:
-- testConsistentlySpacedSyncs
-- testDroppedSyncsSpacing
-- testNoTranslationIfNoOffsetSync
-- testNoTranslationIfStoreNotStarted
-- testOffsetTranslation
-- testPastOffsetTranslation
-- testPastOffsetTranslationWithoutInitializationReadToEnd
-- testRandomlySpacedSyncs
-org.apache.kafka.connect.mirror.OffsetSyncTest:
-- testSerde
-org.apache.kafka.connect.mirror.OffsetSyncWriterTest:
-- testFirePendingOffsetSyncs
-- testMaybeQueueOffsetSyncs
-- testPromoteDelayedOffsetSyncs
-org.apache.kafka.connect.mirror.integration.DedicatedMirrorIntegrationTest:
-- testClusterWithEmitOffsetDisabled
-- testMultiNodeCluster
-- testSingleNodeCluster
-org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest:
-- testNoCheckpointsIfNoRecordsAreMirrored
-- testOffsetSyncsTopicsOnTarget
-- testOffsetTranslationBehindReplicationFlow
-- testOneWayReplicationWithAutoOffsetSync
-- testOneWayReplicationWithFrequentOffsetSyncs
-- testReplicateFromLatest
-- testReplicateSourceDefault
-- testReplicateTargetDefault
-- testReplication
-- testReplicationWithEmptyPartition
-- testReplicationWithoutOffsetSyncWillNotCreateOffsetSyncsTopic
-- testRestartReplication
-- testSyncTopicConfigs
-org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest:
-- testNoCheckpointsIfNoRecordsAreMirrored
-- testOffsetSyncsTopicsOnTarget
-- testOffsetTranslationBehindReplicationFlow
-- testOneWayReplicationWithAutoOffsetSync
-- testOneWayReplicationWithFrequentOffsetSyncs
-- testReplicateFromLatest
-- testReplicateSourceDefault
-- testReplicateTargetDefault
-- testReplication
-- testReplicationWithEmptyPartition
-- testReplicationWithoutOffsetSyncWillNotCreateOffsetSyncsTopic
-- testRestartReplication
-- testSyncTopicConfigs
-org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest:
-- testNoCheckpointsIfNoRecordsAreMirrored
-- testOffsetSyncsTopicsOnTarget
-- testOffsetTranslationBehindReplicationFlow
-- testOneWayReplicationWithAutoOffsetSync
-- testOneWayReplicationWithFrequentOffsetSyncs
-- testReplicateFromLatest
-- testReplicateSourceDefault
-- testReplicateTargetDefault
-- testReplication
-- testReplicationWithEmptyPartition
-- testReplicationWithoutOffsetSyncWillNotCreateOffsetSyncsTopic
-- testRestartReplication
-- testSyncTopicConfigs
-org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest:
-- testNoCheckpointsIfNoRecordsAreMirrored
-- testOffsetSyncsTopicsOnTarget
-- testOffsetTranslationBehindReplicationFlow
-- testOneWayReplicationWithAutoOffsetSync
-- testOneWayReplicationWithFrequentOffsetSyncs
-- testReplicateFromLatest
-- testReplicateSourceDefault
-- testReplicateTargetDefault
-- testReplication
-- testReplicationWithEmptyPartition
-- testReplicationWithoutOffsetSyncWillNotCreateOffsetSyncsTopic
-- testRestartReplication
-- testSyncTopicConfigs
-org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationTransactionsTest:
-- testNoCheckpointsIfNoRecordsAreMirrored
-- testOffsetSyncsTopicsOnTarget
-- testOffsetTranslationBehindReplicationFlow
-- testOneWayReplicationWithAutoOffsetSync
-- testOneWayReplicationWithFrequentOffsetSyncs
-- testReplicateFromLatest
-- testReplicateSourceDefault
-- testReplicateTargetDefault
-- testReplication
-- testReplicationWithEmptyPartition
-- testReplicationWithoutOffsetSyncWillNotCreateOffsetSyncsTopic
-- testRestartReplication
-- testSyncTopicConfigs
-org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest:
-- testCreatePartitionsUseProvidedForwardingAdmin
-- testNoCheckpointsIfNoRecordsAreMirrored
-- testOffsetSyncsTopicsOnTarget
-- testOffsetTranslationBehindReplicationFlow
-- testOneWayReplicationWithAutoOffsetSync
-- testOneWayReplicationWithFrequentOffsetSyncs
-- testReplicateFromLatest
-- testReplicateSourceDefault
-- testReplicateTargetDefault
-- testReplication
-- testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin
-- testReplicationWithEmptyPartition
-- testReplicationWithoutOffsetSyncWillNotCreateOffsetSyncsTopic
-- testRestartReplication
-- testSyncTopicACLsUseProvidedForwardingAdmin
-- testSyncTopicConfigUseProvidedForwardingAdmin
-- testSyncTopicConfigs
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index 6afa44be595..8643c5ecbb2 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -551,12 +551,10 @@ kafka.api.PlaintextConsumerSubscriptionTest:
- testUnsubscribeTopic
kafka.api.PlaintextConsumerTest:
- testAutoOffsetReset
-- testCloseLeavesGroupOnInterrupt
- testClusterResourceListener
- testConsumeMessagesWithCreateTime
- testConsumeMessagesWithLogAppendTime
- testConsumingWithNullGroupId
-- testCoordinatorFailover
- testEndOffsets
- testFetchOffsetsForTime
- testGroupConsumption
@@ -664,7 +662,6 @@ kafka.api.SaslGssapiSslEndToEndAuthorizationTest:
- testTwoConsumersWithDifferentSaslCredentials
kafka.api.SaslMultiMechanismConsumerTest:
- testClusterResourceListener
-- testCoordinatorFailover
- testMultipleBrokerMechanisms
- testSimpleConsumption
kafka.api.SaslOAuthBearerSslEndToEndAuthorizationTest:
@@ -683,11 +680,9 @@ kafka.api.SaslOAuthBearerSslEndToEndAuthorizationTest:
- testTwoConsumersWithDifferentSaslCredentials
kafka.api.SaslPlainPlaintextConsumerTest:
- testClusterResourceListener
-- testCoordinatorFailover
- testSimpleConsumption
kafka.api.SaslPlaintextConsumerTest:
- testClusterResourceListener
-- testCoordinatorFailover
- testSimpleConsumption
kafka.api.SaslScramSslEndToEndAuthorizationTest:
- testAuthentications
@@ -725,7 +720,6 @@ kafka.api.SaslSslAdminIntegrationTest:
- testLegacyAclOpsNeverAffectOrReturnPrefixed
kafka.api.SaslSslConsumerTest:
- testClusterResourceListener
-- testCoordinatorFailover
- testSimpleConsumption
kafka.api.SslAdminIntegrationTest:
- testAclAuthorizationDenied
@@ -752,7 +746,6 @@ kafka.api.SslAdminIntegrationTest:
- testSynchronousAuthorizerAclUpdatesBlockRequestThreads
kafka.api.SslConsumerTest:
- testClusterResourceListener
-- testCoordinatorFailover
- testSimpleConsumption
kafka.api.SslEndToEndAuthorizationTest:
- testNoConsumeWithDescribeAclViaAssign
@@ -786,8 +779,6 @@ kafka.api.TransactionsExpirationTest:
kafka.api.TransactionsTest:
- testAbortTransactionTimeout
- testBasicTransactions
-- testBumpTransactionalEpochWithTV2Disabled
-- testBumpTransactionalEpochWithTV2Enabled
- testCommitTransactionTimeout
- testConsecutivelyRunInitTransactions
- testDelayedFetchIncludesAbortedTransaction
@@ -800,7 +791,6 @@ kafka.api.TransactionsTest:
- testInitTransactionsTimeout
- testMultipleMarkersOneLeader
- testOffsetMetadataInSendOffsetsToTransaction
-- testReadCommittedConsumerShouldNotSeeUndecidedData
- testSendOffsetsToTransactionTimeout
- testSendOffsetsWithGroupMetadata
kafka.api.TransactionsWithMaxInFlightOneTest:
@@ -1286,9 +1276,6 @@
kafka.coordinator.transaction.TransactionCoordinatorConcurrencyTest:
- testConcurrentRandomSequences
- testConcurrentTransactionExpiration
kafka.coordinator.transaction.TransactionCoordinatorTest:
-- TestEndTxnRequestWhenEmptyTransactionStateForAbortInV1
-- TestEndTxnRequestWhenEmptyTransactionStateForAbortInV2
-- TestEndTxnRequestWhenEmptyTransactionStateForCommitInV2
- shouldAbortExpiredTransactionsInOngoingStateAndBumpEpoch
- shouldAbortTransactionOnHandleInitPidWhenExistingTransactionInOngoingState
- shouldAcceptInitPidAndReturnNextPidWhenTransactionalIdIsNull
@@ -1340,7 +1327,6 @@ kafka.coordinator.transaction.TransactionCoordinatorTest:
- shouldReturnInvalidTxnRequestOnEndTxnRequestWhenStatusIsPrepareAbort
- shouldReturnInvalidTxnRequestOnEndTxnV2IfNotEndTxnV2Retry
- shouldReturnOkOnEndTxnV2IfEndTxnV2RetryEpochOverflow
-- shouldReturnOkOnEndTxnWhenStatusIsCompleteAbortAndResultIsAbortInV2
- shouldUseLastEpochToFenceWhenEpochsAreExhausted
-
shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareAbortState
-
shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareCommitState
@@ -1348,11 +1334,6 @@ kafka.coordinator.transaction.TransactionCoordinatorTest:
- testDescribeTransactionsWhileCoordinatorLoading
- testDescribeTransactionsWithEmptyTransactionalId
- testDescribeTransactionsWithExpiringTransactionalId
-- testEndTxnRequestWhenStatusIsCompleteCommitAndResultIsAbortInV1
-- testEndTxnRequestWhenStatusIsCompleteCommitAndResultIsAbortInV2
-- testEndTxnWhenStatusIsCompleteAbortAndResultIsAbortInV1
-- testEndTxnWhenStatusIsCompleteCommitAndResultIsCommitInV1
-- testEndTxnWhenStatusIsCompleteCommitAndResultIsCommitInV2
- testFenceProducerWhenMappingExistsWithDifferentProducerId
- testInitProducerIdStaleCurrentEpochProvided
- testInitProducerIdWithCurrentEpochProvided
@@ -1415,8 +1396,6 @@ kafka.coordinator.transaction.TransactionMetadataTest:
- testFenceProducerAfterEpochsExhausted
- testFenceProducerNotAllowedIfItWouldOverflow
- testInitializeEpoch
-- testInvalidTransitionFromCompleteAbortToFence
-- testInvalidTransitionFromCompleteCommitToFence
- testNormalEpochBump
- testRotateProducerId
- testRotateProducerIdInOngoingState
@@ -1430,9 +1409,6 @@ kafka.coordinator.transaction.TransactionMetadataTest:
- testTolerateUpdateTimeResetDuringProducerIdRotation
- testTolerateUpdateTimeShiftDuringEpochBump
- testTransactionStateIdAndNameMapping
-- testTransitFromCompleteAbortToPrepareAbortInV2
-- testTransitFromCompleteCommitToPrepareAbortInV2
-- testTransitFromEmptyToPrepareAbortInV2
kafka.coordinator.transaction.TransactionStateManagerTest:
- shouldNotRemoveExpiredTransactionalIdsIfLogAppendFails
- shouldNotRemoveOngoingTransactionalIds
@@ -1461,7 +1437,6 @@ kafka.coordinator.transaction.TransactionStateManagerTest:
- testLoadAndRemoveTransactionsForPartition
- testLoadTransactionMetadataContainingSegmentEndingWithEmptyBatch
- testLoadTransactionMetadataWithCorruptedLog
-- testMakeFollowerLoadingPartition
- testPartitionLoadMetric
- testPendingStateNotResetOnRetryAppend
- testSuccessfulReimmigration
@@ -1910,7 +1885,6 @@ kafka.log.remote.RemoteLogManagerTest:
- testFailedCopyShouldDeleteTheDanglingSegment
- testFailedDeleteExpiredSegments
- testFetchNextSegmentWithTxnIndex
-- testFetchOffsetByTimestampWithTieredStorageDoesNotFetchIndexWhenExistsLocally
- testFetchQuotaManagerConfig
- testFetchRemoteLogSegmentMetadata
- testFindHighestRemoteOffset
@@ -2003,7 +1977,6 @@ kafka.network.ConnectionQuotasTest:
- testNonDefaultConnectionCountLimitAndRateLimit
- testRejectedIpConnectionUnrecordedFromConnectionRateQuotas
kafka.network.DynamicConnectionQuotaTest:
-- testDynamicConnectionQuota
- testDynamicIpConnectionRateQuota
- testDynamicListenerConnectionCreationRateQuota
- testDynamicListenerConnectionQuota
@@ -2095,7 +2068,6 @@ kafka.raft.KafkaMetadataLogTest:
- testCreateSnapshotBeforeLogStartOffset
- testCreateSnapshotDivergingEpoch
- testCreateSnapshotFromEndOffset
-- testCreateSnapshotInMiddleOfBatch
- testCreateSnapshotLaterThanHighWatermark
- testCreateSnapshotMuchLaterEpoch
- testCreateSnapshotOlderEpoch
@@ -2411,14 +2383,12 @@ kafka.server.ConfigAdminManagerTest:
- testValidateResourceNameIsCurrentNodeId
kafka.server.ConsumerGroupDescribeRequestTest:
- testConsumerGroupDescribeWhenFeatureFlagNotEnabled
-- testConsumerGroupDescribeWithMigrationMember
- testConsumerGroupDescribeWithNewGroupCoordinator
kafka.server.ConsumerGroupHeartbeatRequestTest:
- testConsumerGroupHeartbeatFailureIfMemberIdMissingForVersionsAbove0
- testConsumerGroupHeartbeatIsAccessibleWhenNewGroupCoordinatorIsEnabled
- testConsumerGroupHeartbeatIsInaccessibleWhenDisabledByStaticConfig
- testConsumerGroupHeartbeatIsInaccessibleWhenFeatureFlagNotEnabled
-- testConsumerGroupHeartbeatWithEmptySubscription
- testConsumerGroupHeartbeatWithInvalidRegularExpression
- testConsumerGroupHeartbeatWithRegularExpression
- testMemberIdGeneratedOnServerWhenApiVersionIs0
@@ -2436,7 +2406,6 @@ kafka.server.ConsumerProtocolMigrationTest:
- testOnlineMigrationWithCooperativeAssignmentStrategyAndStaticMembers
- testOnlineMigrationWithEagerAssignmentStrategyAndDynamicMembers
- testOnlineMigrationWithEagerAssignmentStrategyAndStaticMembers
-- testOnlineMigrationWithNonEmptyUserDataInAssignment
- testUpgradeFromEmptyClassicToConsumerGroupWithBidirectionalPolicy
- testUpgradeFromEmptyClassicToConsumerGroupWithDisabledPolicy
- testUpgradeFromEmptyClassicToConsumerGroupWithDowngradePolicy
@@ -3226,7 +3195,6 @@ kafka.server.KafkaRequestHandlerTest:
- testSingularLogSizeBytesMetric
- testTopicStats
kafka.server.LeaveGroupRequestTest:
-- testLeaveGroupWithNewConsumerGroupProtocolAndNewGroupCoordinator
- testLeaveGroupWithOldConsumerGroupProtocolAndNewGroupCoordinator
- testLeaveGroupWithOldConsumerGroupProtocolAndOldGroupCoordinator
kafka.server.ListGroupsRequestTest:
@@ -3358,7 +3326,6 @@ kafka.server.OffsetsForLeaderEpochRequestTest:
kafka.server.PermissiveControllerMutationQuotaTest:
- testControllerMutationQuotaViolation
kafka.server.ProduceRequestTest:
-- quorum
- testCorruptLz4ProduceRequest
- testProduceToNonReplica
- testSimpleProduceRequest
@@ -3434,7 +3401,6 @@ kafka.server.ReplicaManagerTest:
- testApplyDeltaShouldHandleReplicaAssignedToLostDirectory
- testApplyDeltaShouldHandleReplicaAssignedToOnlineDirectory
- testApplyDeltaShouldHandleReplicaAssignedToUnassignedDirectory
-- testBecomeFollowerInvokeOnBecomingFollowerListener
- testBecomeFollowerWhenLeaderIsUnchangedButMissedLeaderUpdate
- testBecomeFollowerWhenLeaderIsUnchangedButMissedLeaderUpdateIbp26
- testBecomeFollowerWhileNewClientFetchInPurgatory
@@ -3614,10 +3580,6 @@ kafka.server.TierStateMachineTest:
- testFencedOffsetResetAfterMovedToRemoteTier
- testFollowerFetchMovedToTieredStore
- testFollowerFetchOffsetOutOfRangeWithTieredStore
-kafka.server.TxnOffsetCommitRequestTest:
-- testTxnOffsetCommitWithNewConsumerGroupProtocolAndNewGroupCoordinator
-- testTxnOffsetCommitWithOldConsumerGroupProtocolAndNewGroupCoordinator
-- testTxnOffsetCommitWithOldConsumerGroupProtocolAndOldGroupCoordinator
kafka.server.epoch.LeaderEpochFileCacheTest:
- shouldAddEpochAndMessageOffsetToCache
- shouldClearAllEntries
@@ -3708,7 +3670,6 @@ kafka.server.share.ShareFetchUtilsTest:
- testProcessFetchResponseWithEmptyRecords
- testProcessFetchResponseWithLsoMovementForTopicPartition
- testProcessFetchResponseWithMaxFetchRecords
-- testProcessFetchResponseWithOffsetFetchException
kafka.server.share.SharePartitionManagerTest:
- testAcknowledgeCompletesDelayedShareFetchRequest
- testAcknowledgeDoesNotCompleteDelayedShareFetchRequest
@@ -3722,7 +3683,6 @@ kafka.server.share.SharePartitionManagerTest:
- testCloseSharePartitionManager
- testDelayedInitializationShouldCompleteFetchRequest
- testGetErroneousAndValidTopicIdPartitions
-- testListenerRegistration
- testMultipleConcurrentShareFetches
- testMultipleSequentialShareFetches
- testNewContext
@@ -3746,9 +3706,6 @@ kafka.server.share.SharePartitionManagerTest:
- testSharePartitionInitializationExceptions
- testSharePartitionInitializationFailure
- testSharePartitionKey
-- testSharePartitionListenerOnBecomingFollower
-- testSharePartitionListenerOnDeleted
-- testSharePartitionListenerOnFailed
- testSharePartitionPartialInitializationFailure
- testShareSessionExpiration
- testShareSessionUpdateTopicIdsBrokerSide
@@ -3783,7 +3740,6 @@ kafka.server.share.SharePartitionTest:
- testAcquireWithEmptyFetchRecords
- testAcquireWithMaxFetchRecords
- testAcquireWithMultipleBatchesAndMaxFetchRecords
-- testAcquireWithWriteShareGroupStateDelay
- testAcquisitionLockAfterDifferentAcknowledges
- testAcquisitionLockForAcquiringMultipleRecords
- testAcquisitionLockForAcquiringMultipleRecordsWithOverlapAndNewBatch
@@ -3897,23 +3853,15 @@ kafka.server.share.SharePartitionTest:
- 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
@@ -3922,7 +3870,6 @@ kafka.test.api.ShareConsumerTest:
- testImplicitAcknowledgementCommitAsync
- testLsoMovementByRecordsDeletion
- testMaxPollRecords
-- testMultipleConsumersInGroupConcurrentConsumption
- testMultipleConsumersInGroupFailureConcurrentConsumption
- testMultipleConsumersInGroupSequentialConsumption
- testMultipleConsumersInMultipleGroupsConcurrentConsumption
diff --git a/test-catalog/raft/tests.yaml b/test-catalog/raft/tests.yaml
index 855de089188..b3bbdd1cb4a 100644
--- a/test-catalog/raft/tests.yaml
+++ b/test-catalog/raft/tests.yaml
@@ -437,14 +437,6 @@ org.apache.kafka.raft.QuorumStateTest:
- testUnattachedVotedToUnattachedHigherEpoch
- testUnattachedVotedToUnattachedSameEpoch
- testUnattachedVotedToUnattachedVotedSameEpoch
-org.apache.kafka.raft.RaftEventSimulationTest:
-- canElectInitialLeader
-- canElectNewLeaderAfterOldLeaderFailure
-- canElectNewLeaderAfterOldLeaderPartitionedAway
-- canMakeProgressAfterBackToBackLeaderFailures
-- canMakeProgressIfMajorityIsReachable
-- canRecoverAfterAllNodesKilled
-- canRecoverFromSingleNodeCommittedDataLoss
org.apache.kafka.raft.RaftUtilTest:
- testErrorResponse
- testSingletonBeginQuorumEpochRequestForAllVersion
@@ -565,10 +557,7 @@ org.apache.kafka.raft.internals.RecordsIteratorTest:
- testControlRecordIterationWithKraftVersion0
- testControlRecordIterationWithKraftVersion1
- testControlRecordTypeValues
-- testCrcValidation
- testEmptyRecords
-- testFileRecords
-- testMemoryRecords
- testWithAllSupportedControlRecords
org.apache.kafka.raft.internals.ThresholdPurgatoryTest:
- testCompleteAll
diff --git a/test-catalog/storage/tests.yaml b/test-catalog/storage/tests.yaml
index a3eae512cb8..c138b24a84d 100644
--- a/test-catalog/storage/tests.yaml
+++ b/test-catalog/storage/tests.yaml
@@ -124,44 +124,6 @@
org.apache.kafka.storage.internals.checkpoint.PartitionMetadataFileTest:
- testRead
- testSetRecordWithDifferentTopicId
- testSetRecordWithSameTopicId
-org.apache.kafka.storage.internals.log.LocalLogTest:
-- testCreateAndDeleteSegment
-- testDeleteSegmentFilesAsync
-- testDeleteSegmentFilesSync
-- testFlushingNonExistentDir
-- testLogAppend
-- testLogCloseFailureWhenInMemoryBufferClosed
-- testLogCloseHandlers
-- testLogCloseHandlersIdempotent
-- testLogCloseIdempotent
-- testLogCloseSuccess
-- testLogDeleteDirName
-- testLogDeleteDirSuccessWhenEmptyAndFailureWhenNonEmpty
-- testLogDeleteSegmentsSuccess
-- testLogDirRenameToExistingDir
-- testLogDirRenameToNewDir
-- testLogFlush
-- testNewSegmentsAfterRoll
-- testNonActiveSegmentsFrom
-- testOffsetFromFile
-- testParseTopicPartitionName
-- testParseTopicPartitionNameForEmptyName
-- testParseTopicPartitionNameForExistingInvalidDir
-- testParseTopicPartitionNameForInvalidPartition
-- testParseTopicPartitionNameForMissingPartition
-- testParseTopicPartitionNameForMissingSeparator
-- testParseTopicPartitionNameForMissingTopic
-- testParseTopicPartitionNameForNull
-- testParseTopicPartitionNameWithPeriodForDeletedTopic
-- testRemoveAndDeleteSegmentsAsync
-- testRemoveAndDeleteSegmentsSync
-- testRollEmptyActiveSegment
-- testRollSegmentErrorWhenNextOffsetIsIllegal
-- testRollSegmentThatAlreadyExists
-- testTruncateFullyAndStartAt
-- testTruncateTo
-- testUpdateConfig
-- testWhenFetchOffsetHigherThanMaxOffset
org.apache.kafka.storage.internals.log.LogOffsetMetadataTest:
- testMessageOffsetOnly
- testOnOlderSegment
@@ -356,9 +318,6 @@ org.apache.kafka.storage.internals.log.TransactionIndexTest:
- testSanityCheck
- testTruncate
- testUpdateParentDir
-org.apache.kafka.storage.internals.log.VerificationGuardTest:
-- testEqualsAndHashCode
-- testVerify
org.apache.kafka.storage.internals.utils.ThrottlerTest:
- testThrottleDesiredRate
- testUpdateThrottleDesiredRate
@@ -397,8 +356,6 @@
org.apache.kafka.tiered.storage.integration.RollAndOffloadActiveSegmentTest:
org.apache.kafka.tiered.storage.integration.TransactionsWithTieredStoreTest:
- testAbortTransactionTimeout
- testBasicTransactions
-- testBumpTransactionalEpochWithTV2Disabled
-- testBumpTransactionalEpochWithTV2Enabled
- testCommitTransactionTimeout
- testConsecutivelyRunInitTransactions
- testDelayedFetchIncludesAbortedTransaction
@@ -411,6 +368,5 @@
org.apache.kafka.tiered.storage.integration.TransactionsWithTieredStoreTest:
- testInitTransactionsTimeout
- testMultipleMarkersOneLeader
- testOffsetMetadataInSendOffsetsToTransaction
-- testReadCommittedConsumerShouldNotSeeUndecidedData
- testSendOffsetsToTransactionTimeout
- testSendOffsetsWithGroupMetadata
diff --git a/test-catalog/streams/integration-tests/tests.yaml
b/test-catalog/streams/integration-tests/tests.yaml
deleted file mode 100644
index cba7e48ca06..00000000000
--- a/test-catalog/streams/integration-tests/tests.yaml
+++ /dev/null
@@ -1,360 +0,0 @@
-org.apache.kafka.streams.integration.AdjustStreamThreadCountTest:
-- shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect
-- shouldAddAndRemoveThreadsMultipleTimes
-- shouldAddStreamThread
-- shouldRemoveStreamThread
-- shouldRemoveStreamThreadWithStaticMembership
-- shouldResizeCacheAfterThreadRemovalTimesOut
-- shouldResizeCacheAfterThreadReplacement
-- shouldnNotRemoveStreamThreadWithinTimeout
-- testConcurrentlyAccessThreads
-- testRebalanceHappensBeforeStreamThreadGetDown
-org.apache.kafka.streams.integration.ConsistencyVectorIntegrationTest:
-- shouldHaveSamePositionBoundActiveAndStandBy
-org.apache.kafka.streams.integration.EOSUncleanShutdownIntegrationTest:
-- shouldWorkWithUncleanShutdownWipeOutStateStore
-org.apache.kafka.streams.integration.EmitOnChangeIntegrationTest:
-- shouldEmitSameRecordAfterFailover
-org.apache.kafka.streams.integration.EosIntegrationTest:
-- shouldBeAbleToCommitMultiplePartitionOffsets
-- shouldBeAbleToCommitToMultiplePartitions
-- shouldBeAbleToPerformMultipleTransactions
-- shouldBeAbleToRestartAfterClose
-- shouldBeAbleToRunWithEosEnabled
-- shouldBeAbleToRunWithTwoSubtopologies
-- shouldBeAbleToRunWithTwoSubtopologiesAndMultiplePartitions
--
shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoringStateUpdaterDisabled
--
shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoringStateUpdaterEnabled
-- shouldCommitCorrectOffsetIfInputTopicIsTransactional
-- shouldNotViolateEosIfOneTaskFails
-- shouldNotViolateEosIfOneTaskFailsWithState
-- shouldNotViolateEosIfOneTaskGetsFencedUsingIsolatedAppInstances
-- shouldWriteLatestOffsetsToCheckpointOnShutdown
-org.apache.kafka.streams.integration.FineGrainedAutoResetIntegrationTest:
-- shouldOnlyReadRecordsWhereEarliestSpecifiedWithInvalidCommittedOffsets
--
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithDefaultGlobalAutoOffsetResetEarliest
--
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest
-- shouldThrowExceptionOverlappingPattern
-- shouldThrowExceptionOverlappingTopic
-- shouldThrowStreamsExceptionNoResetSpecified
-org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest:
-- shouldKStreamGlobalKTableJoin
-- shouldKStreamGlobalKTableLeftJoin
-- shouldNotRestoreAbortedMessages
-- shouldRestoreTransactionalMessages
-- shouldSkipOverAbortedMessagesOnRestore
-- shouldSkipOverTxMarkersOnRestore
-org.apache.kafka.streams.integration.GlobalKTableIntegrationTest:
-- shouldGetToRunningWithOnlyGlobalTopology
-- shouldKStreamGlobalKTableJoin
-- shouldKStreamGlobalKTableLeftJoin
-- shouldRestoreGlobalInMemoryKTableOnRestart
-org.apache.kafka.streams.integration.GlobalStateReprocessTest:
-- shouldReprocessWithUserProvidedStore
-org.apache.kafka.streams.integration.GlobalThreadShutDownOrderTest:
-- shouldFinishGlobalStoreOperationOnShutDown
-org.apache.kafka.streams.integration.HandlingSourceTopicDeletionIntegrationTest:
-- shouldThrowErrorAfterSourceTopicDeleted
-org.apache.kafka.streams.integration.HighAvailabilityTaskAssignorIntegrationTest:
-- shouldScaleOutWithWarmupTasksAndInMemoryStores
-- shouldScaleOutWithWarmupTasksAndPersistentStores
-org.apache.kafka.streams.integration.IQv2IntegrationTest:
-- shouldFailNotStarted
-- shouldFailStopped
-- shouldFailUnknownStore
-- shouldFetchExplicitlyFromAllPartitions
-- shouldFetchFromPartition
-- shouldNotRequireQueryHandler
-- shouldRejectNonRunningActive
-org.apache.kafka.streams.integration.IQv2StoreIntegrationTest:
-- verifyStore
-org.apache.kafka.streams.integration.IQv2VersionedStoreIntegrationTest:
-- verifyStore
-org.apache.kafka.streams.integration.InternalTopicIntegrationTest:
-- shouldCompactAndDeleteTopicsForWindowStoreChangelogs
-- shouldCompactTopicsForKeyValueStoreChangelogs
-- shouldGetToRunningWithWindowedTableInFKJ
-org.apache.kafka.streams.integration.JoinGracePeriodDurabilityIntegrationTest:
-- shouldRecoverBufferAfterShutdown
-org.apache.kafka.streams.integration.JoinStoreIntegrationTest:
-- providingAJoinStoreNameShouldNotMakeTheJoinResultQueryable
-- streamJoinChangelogTopicShouldBeConfiguredWithDeleteOnlyCleanupPolicy
-org.apache.kafka.streams.integration.JoinWithIncompleteMetadataIntegrationTest:
-- testShouldAutoShutdownOnJoinWithIncompleteMetadata
-org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest:
-- shouldGroupByKey
-- shouldReduce
-- shouldReduceWindowed
-org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest:
-- shouldAggregate
-- shouldAggregateSlidingWindows
-- shouldAggregateWindowed
-- shouldCount
-- shouldCountSessionWindows
-- shouldCountUnlimitedWindows
-- shouldCountWithInternalStore
-- shouldGroupByKey
-- shouldReduce
-- shouldReduceSessionWindows
-- shouldReduceSlidingWindows
-- shouldReduceWindowed
-org.apache.kafka.streams.integration.KStreamKStreamIntegrationTest:
-- shouldOuterJoin
-org.apache.kafka.streams.integration.KStreamRepartitionIntegrationTest:
-- shouldCreateOnlyOneRepartitionTopicWhenRepartitionIsFollowedByGroupByKey
-- shouldCreateRepartitionTopicIfKeyChangingOperationWasNotPerformed
-- shouldCreateRepartitionTopicWithSpecifiedNumberOfPartitions
-- shouldDeductNumberOfPartitionsFromRepartitionOperation
--
shouldDoProperJoiningWhenNumberOfPartitionsAreValidWhenUsingRepartitionOperation
-- shouldGenerateRepartitionTopicWhenNameIsNotSpecified
-- shouldGoThroughRebalancingCorrectly
--
shouldInheritRepartitionTopicPartitionNumberFromUpstreamTopicWhenNumberOfPartitionsIsNotSpecified
-- shouldPerformKeySelectOperationWhenRepartitionOperationIsUsedWithKeySelector
-- shouldPerformSelectKeyWithRepartitionOperation
-- shouldRepartitionToMultiplePartitions
--
shouldThrowAnExceptionWhenNumberOfPartitionsOfRepartitionOperationDoNotMatchSourceTopicWhenJoining
-- shouldUseStreamPartitionerForRepartitionOperation
-org.apache.kafka.streams.integration.KTableEfficientRangeQueryTest:
-- testStoreConfig
-org.apache.kafka.streams.integration.KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest:
-- shouldInnerJoinMultiPartitionQueryable
--
shouldThrowIllegalArgumentExceptionWhenCustomPartitionerReturnsMultiplePartitions
-org.apache.kafka.streams.integration.KTableKTableForeignKeyInnerJoinMultiIntegrationTest:
-- shouldInnerJoinMultiPartitionQueryable
-org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinDistributedTest:
-- shouldBeInitializedWithDefaultSerde
-org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest:
-- doJoinFromLeftThenDeleteLeftEntity
-- doJoinFromRightThenDeleteRightEntity
-- joinShouldProduceNullsWhenValueHasNonMatchingForeignKey
-- shouldEmitRecordOnNullForeignKeyForLeftJoins
-- shouldEmitRecordWhenOldAndNewFkDiffer
-- shouldEmitTombstoneWhenDeletingNonJoiningRecords
-- shouldIgnoreOutOfOrderRecordsIffVersioned
-- shouldNotEmitTombstonesWhenDeletingNonExistingRecords
-- shouldUnsubscribeOldForeignKeyIfLeftSideIsUpdated
-org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinMaterializationIntegrationTest:
-- shouldEmitTombstoneWhenDeletingNonJoiningRecords
-org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest:
-- shouldRestoreAndProgressWhenTopicNotWrittenToDuringRestoration
-- shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosDisabled
-- shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosV2Enabled
-org.apache.kafka.streams.integration.KafkaStreamsCloseOptionsIntegrationTest:
-- testCloseOptions
-org.apache.kafka.streams.integration.KafkaStreamsTelemetryIntegrationTest:
-- passedMetricsShouldNotLeakIntoClientMetrics
-- shouldPassCorrectMetricsDynamicInstances
-- shouldPassMetrics
-- shouldPushMetricsToBroker
-org.apache.kafka.streams.integration.LagFetchIntegrationTest:
-- shouldFetchLagsDuringRebalancingWithNoOptimization
-- shouldFetchLagsDuringRebalancingWithOptimization
-- shouldFetchLagsDuringRestoration
-org.apache.kafka.streams.integration.MetricsIntegrationTest:
-- shouldAddMetricsForSessionStore
-- shouldAddMetricsForWindowStoreAndSuppressionBuffer
-- shouldAddMetricsOnAllLevels
-org.apache.kafka.streams.integration.MetricsReporterIntegrationTest:
-- shouldBeAbleToProvideInitialMetricValueToMetricsReporter
-org.apache.kafka.streams.integration.NamedTopologyIntegrationTest:
-- shouldAddNamedTopologyToRunningApplicationWithEmptyInitialTopology
-- shouldAddNamedTopologyToRunningApplicationWithMultipleNodes
-- shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopology
--
shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopologyWithRepartitioning
-- shouldAllowMixedCollectionAndPatternSubscriptionWithMultipleNamedTopologies
-- shouldAllowPatternSubscriptionWithMultipleNamedTopologies
--
shouldAllowRemovingAndAddingNamedTopologyToRunningApplicationWithMultipleNodesAndResetsOffsets
-- shouldPrefixAllInternalTopicNamesWithNamedTopology
--
shouldProcessMultipleIdenticalNamedTopologiesWithInMemoryAndPersistentStateStores
-- shouldProcessSingleNamedTopologyAndPrefixInternalTopics
-- shouldRemoveAndReplaceTopologicallyIncompatibleNamedTopology
-org.apache.kafka.streams.integration.OptimizedKTableIntegrationTest:
-- shouldApplyUpdatesToStandbyStore
-org.apache.kafka.streams.integration.PauseResumeIntegrationTest:
-- pauseResumeShouldWorkAcrossInstances
-- pausedTopologyShouldNotRestoreStateStores
-- shouldAllowForNamedTopologiesToStartPaused
-- shouldAllowForTopologiesToStartPaused
-- shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies
-- shouldPauseAndResumeKafkaStreams
-- shouldPauseAndResumeKafkaStreamsWithNamedTopologies
-org.apache.kafka.streams.integration.PositionRestartIntegrationTest:
-- verifyStore
-org.apache.kafka.streams.integration.ProcessingExceptionHandlerIntegrationTest:
--
shouldContinueWhenProcessingExceptionOccursFromFlushingCacheIfExceptionHandlerReturnsContinue
-- shouldContinueWhenProcessingExceptionOccursIfExceptionHandlerReturnsContinue
--
shouldFailWhenProcessingExceptionOccursFromFlushingCacheIfExceptionHandlerReturnsFail
-- shouldFailWhenProcessingExceptionOccursIfExceptionHandlerReturnsFail
--
shouldStopOnFailedProcessorWhenProcessingExceptionOccursInContinueProcessingExceptionHandler
--
shouldStopOnFailedProcessorWhenProcessingExceptionOccursInFailProcessingExceptionHandler
-- shouldStopProcessingWhenFatalUserExceptionProcessingExceptionHandler
-- shouldStopProcessingWhenProcessingExceptionHandlerReturnsNull
-org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest:
-- shouldRestoreState
-org.apache.kafka.streams.integration.QueryableStateIntegrationTest:
-- shouldAllowToQueryAfterThreadDied
-- shouldBeAbleQueryStandbyStateDuringRebalance
-- shouldBeAbleToQueryDuringRebalance
-- shouldBeAbleToQueryFilterState
-- shouldBeAbleToQueryKeysWithGivenPrefix
-- shouldBeAbleToQueryMapValuesAfterFilterState
-- shouldBeAbleToQueryMapValuesState
-- shouldBeAbleToQueryStateWithNonZeroSizedCache
-- shouldBeAbleToQueryStateWithZeroSizedCache
-- shouldNotMakeStoreAvailableUntilAllStoresAvailable
-- shouldRejectNonExistentStoreName
-- shouldRejectWronglyTypedStore
-org.apache.kafka.streams.integration.RangeQueryIntegrationTest:
-- testStoreConfig
-org.apache.kafka.streams.integration.RegexSourceIntegrationTest:
-- shouldAddStateStoreToRegexDefinedSource
-- testMultipleConsumersCanReadFromPartitionedTopic
-- testNoMessagesSentExceptionFromOverlappingPatterns
-- testRegexMatchesTopicsAWhenCreated
-- testRegexMatchesTopicsAWhenDeleted
-- testRegexRecordsAreProcessedAfterNewTopicCreatedWithMultipleSubtopologies
-- testShouldReadFromRegexAndNamedTopics
-org.apache.kafka.streams.integration.RelaxedNullKeyRequirementJoinTest:
-- testDropNullKeyRecordsForRepartitionNodesWithNoRelaxedJoinDownstream
-- testRelaxedLeftStreamGlobalTableJoin
-- testRelaxedLeftStreamStreamJoin
-- testRelaxedLeftStreamTableJoin
-- testRelaxedOuterStreamStreamJoin
-org.apache.kafka.streams.integration.ResetPartitionTimeIntegrationTest:
-- shouldPreservePartitionTimeOnKafkaStreamRestart
-org.apache.kafka.streams.integration.RestoreIntegrationTest:
-- shouldInvokeUserDefinedGlobalStateRestoreListener
-- shouldProcessDataFromStoresWithLoggingDisabled
-- shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore
-- shouldRestoreNullRecord
-- shouldRestoreStateFromChangelogTopic
-- shouldRestoreStateFromSourceTopicForGlobalTable
-- shouldRestoreStateFromSourceTopicForReadOnlyStore
-- shouldSuccessfullyStartWhenLoggingDisabled
-org.apache.kafka.streams.integration.RocksDBMetricsIntegrationTest:
-- shouldExposeRocksDBMetricsBeforeAndAfterFailureWithEmptyStateDir
-org.apache.kafka.streams.integration.SelfJoinUpgradeIntegrationTest:
-- shouldRestartWithTopologyOptimizationOn
-- shouldUpgradeWithTopologyOptimizationOff
-org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest:
-- shouldAggregateWindowedWithGrace
-- shouldAggregateWindowedWithNoGrace
-- shouldRestoreAfterJoinRestart
-org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest:
-- shouldWorkWithRebalance
-org.apache.kafka.streams.integration.StandbyTaskCreationIntegrationTest:
-- shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables
-- shouldNotCreateAnyStandByTasksForStateStoreWithLoggingDisabled
-org.apache.kafka.streams.integration.StandbyTaskEOSIntegrationTest:
-- shouldSurviveWithOneTaskAsStandby
-- shouldWipeOutStandbyStateDirectoryIfCheckpointIsMissing
-org.apache.kafka.streams.integration.StandbyTaskEOSMultiRebalanceIntegrationTest:
-- shouldHonorEOSWhenUsingCachingAndStandbyReplicas
-org.apache.kafka.streams.integration.StateDirectoryIntegrationTest:
-- testCleanUpStateDirIfEmpty
-- testNotCleanUpStateDirIfNotEmpty
-org.apache.kafka.streams.integration.StoreQueryIntegrationTest:
--
shouldFailWithIllegalArgumentExceptionWhenIQPartitionerReturnsMultiplePartitions
-- shouldQueryAllStalePartitionStores
-- shouldQueryOnlyActivePartitionStoresByDefault
-- shouldQuerySpecificActivePartitionStores
-- shouldQuerySpecificStalePartitionStores
-- shouldQuerySpecificStalePartitionStoresMultiStreamThreads
-- shouldQuerySpecificStalePartitionStoresMultiStreamThreadsNamedTopology
-- shouldQueryStoresAfterAddingAndRemovingStreamThread
-org.apache.kafka.streams.integration.StoreUpgradeIntegrationTest:
-- shouldMigrateInMemoryKeyValueStoreToTimestampedKeyValueStoreUsingPapi
-- shouldMigrateInMemoryWindowStoreToTimestampedWindowStoreUsingPapi
-- shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapi
-- shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi
-- shouldProxyKeyValueStoreToTimestampedKeyValueStoreUsingPapi
-- shouldProxyWindowStoreToTimestampedWindowStoreUsingPapi
-org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest:
-- testInner
-- testInnerRepartitioned
-- testLeft
-- testLeftRepartitioned
-- testMultiInner
-- testOuter
-- testOuterRepartitioned
-- testSelfJoin
-org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest:
-- testInner
-- testInnerWithVersionedStore
-- testLeft
-- testLeftWithVersionedStore
-org.apache.kafka.streams.integration.StreamTableJoinTopologyOptimizationIntegrationTest:
-- shouldDoStreamTableJoinWithDifferentNumberOfPartitions
-org.apache.kafka.streams.integration.StreamTableJoinWithGraceIntegrationTest:
-- testInnerWithVersionedStore
-- testLeftWithVersionedStore
-org.apache.kafka.streams.integration.StreamToTableJoinScalaIntegrationTestImplicitSerdes:
-- testShouldCountClicksPerRegion
-- testShouldCountClicksPerRegionJava
-- testShouldCountClicksPerRegionWithNamedRepartitionTopic
-org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest:
-- shouldEmitSameRecordAfterFailover
-- shouldReplaceSingleThread
-- shouldReplaceThreads
-- shouldReplaceThreadsWithoutJavaHandler
-- shouldShutDownClientIfGlobalStreamThreadWantsToReplaceThread
-- shouldShutdownClient
-- shouldShutdownMultipleThreadApplication
-- shouldShutdownSingleThreadApplication
-org.apache.kafka.streams.integration.StreamsUpgradeTestIntegrationTest:
-- testVersionProbingUpgrade
-org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest:
-- shouldRecoverBufferAfterShutdown
-org.apache.kafka.streams.integration.SuppressionIntegrationTest:
-- shouldAllowDisablingChangelog
-- shouldAllowOverridingChangelogConfig
-- shouldCreateChangelogByDefault
-- shouldInheritSerdes
-- shouldShutdownWhenBytesConstraintIsViolated
-- shouldShutdownWhenRecordConstraintIsViolated
-- shouldUseDefaultSerdes
-org.apache.kafka.streams.integration.SwallowUnknownTopicErrorIntegrationTest:
-- shouldThrowStreamsExceptionWithMissingTopicAndDefaultExceptionHandler
-org.apache.kafka.streams.integration.TableTableJoinIntegrationTest:
-- testInner
-- testInnerInner
-- testInnerLeft
-- testInnerOuter
-- testInnerWithLeftVersionedOnly
-- testInnerWithRightVersionedOnly
-- testInnerWithVersionedStores
-- testLeft
-- testLeftInner
-- testLeftLeft
-- testLeftOuter
-- testLeftWithLeftVersionedOnly
-- testLeftWithRightVersionedOnly
-- testLeftWithVersionedStores
-- testOuter
-- testOuterInner
-- testOuterLeft
-- testOuterOuter
-- testOuterWithLeftVersionedOnly
-- testOuterWithRightVersionedOnly
-- testOuterWithVersionedStores
-org.apache.kafka.streams.integration.TaskAssignorIntegrationTest:
-- shouldProperlyConfigureTheAssignor
-org.apache.kafka.streams.integration.TaskMetadataIntegrationTest:
-- shouldReportCorrectCommittedOffsetInformation
-- shouldReportCorrectEndOffsetInformation
-org.apache.kafka.streams.integration.TimeWindowedKStreamIntegrationTest:
-- shouldAggregateWindowedWithGrace
-- shouldAggregateWindowedWithNoGrace
-- shouldRestoreAfterJoinRestart
-- shouldThrowUnlimitedWindows
-org.apache.kafka.streams.integration.VersionedKeyValueStoreIntegrationTest:
-- shouldAllowCustomIQv2ForCustomStoreImplementations
-- shouldManualUpgradeFromNonVersionedNonTimestampedToVersioned
-- shouldManualUpgradeFromNonVersionedTimestampedToVersioned
-- shouldPutGetAndDelete
-- shouldRestore
-- shouldSetChangelogTopicProperties
-org.apache.kafka.streams.integration.WordCountTest:
-- testShouldCountWords
-- testShouldCountWordsJava
-- testShouldCountWordsMaterialized
diff --git a/test-catalog/tools/tests.yaml b/test-catalog/tools/tests.yaml
index 9cecc3f4708..fd3784aac1b 100644
--- a/test-catalog/tools/tests.yaml
+++ b/test-catalog/tools/tests.yaml
@@ -486,9 +486,6 @@
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
