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 f9d13c05777 Update test catalog data for GHA workflow run 11627885874
f9d13c05777 is described below
commit f9d13c057770a3129db30f11cdec10f9531c5bc8
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Nov 1 12:56:10 2024 +0000
Update test catalog data for GHA workflow run 11627885874
Commit:
https://github.com/apache/kafka/commit/5a3b544d6172d9811b28eacd9e4a1c55c5dd5e8d
GitHub Run: https://github.com/apache/kafka/actions/runs/11627885874
---
test-catalog/streams/integration-tests/tests.yaml | 389 ++++++++++++++++++++++
test-catalog/streams/streams-scala/tests.yaml | 8 -
test-catalog/streams/tests.yaml | 381 ---------------------
3 files changed, 389 insertions(+), 389 deletions(-)
diff --git a/test-catalog/streams/integration-tests/tests.yaml
b/test-catalog/streams/integration-tests/tests.yaml
new file mode 100644
index 00000000000..1fc7b78828d
--- /dev/null
+++ b/test-catalog/streams/integration-tests/tests.yaml
@@ -0,0 +1,389 @@
+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.KStreamTransformIntegrationTest:
+- shouldFlatTransform
+- shouldFlatTransformValuesWithKey
+- shouldFlatTransformValuesWithKeyWithConnectedStoreProvider
+- shouldFlatTransformValuesWithValueTransformerWithoutKey
+-
shouldFlatTransformValuesWithValueTransformerWithoutKeyWithConnectedStoreProvider
+- shouldFlatTransformWithConnectedStoreProvider
+- shouldTransform
+- shouldTransformValuesWithValueTransformerWithKey
+- shouldTransformValuesWithValueTransformerWithKeyWithConnectedStoreProvider
+- shouldTransformValuesWithValueTransformerWithoutKey
+- shouldTransformValuesWithValueTransformerWithoutKeyWithConnectedStoreProvider
+- shouldTransformWithConnectedStoreProvider
+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.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:
+-
shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology
+- shouldAddNamedTopologyToRunningApplicationWithEmptyInitialTopology
+- shouldAddNamedTopologyToRunningApplicationWithMultipleInitialNamedTopologies
+- shouldAddNamedTopologyToRunningApplicationWithMultipleNodes
+- shouldAddNamedTopologyToRunningApplicationWithSingleInitialNamedTopology
+- 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:
+- shouldContinueWhenProcessingExceptionOccursIfExceptionHandlerReturnsContinue
+- 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.ResetIntegrationTest:
+- shouldNotAllowToResetWhenInputTopicAbsent
+- shouldNotAllowToResetWhenIntermediateTopicAbsent
+- shouldNotAllowToResetWhenSpecifiedInternalTopicDoesNotExist
+- shouldNotAllowToResetWhenSpecifiedInternalTopicIsNotInternal
+- shouldNotAllowToResetWhileStreamsIsRunning
+- testReprocessingByDurationAfterResetWithoutIntermediateUserTopic
+- testReprocessingFromDateTimeAfterResetWithoutIntermediateUserTopic
+- testReprocessingFromFileAfterResetWithoutIntermediateUserTopic
+- testReprocessingFromScratchAfterResetWithIntermediateInternalTopic
+- testReprocessingFromScratchAfterResetWithIntermediateUserTopic
+- testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
+- testResetWhenInternalTopicsAreSpecified
+- testResetWhenLongSessionTimeoutConfiguredWithForceOption
+org.apache.kafka.streams.integration.ResetIntegrationWithSslTest:
+- testReprocessingFromScratchAfterResetWithIntermediateInternalTopic
+- testReprocessingFromScratchAfterResetWithIntermediateUserTopic
+- testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
+- testResetWhenInternalTopicsAreSpecified
+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
+- shouldShutdownThreadUsingOldHandler
+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/streams/streams-scala/tests.yaml
b/test-catalog/streams/streams-scala/tests.yaml
index 0eafd4ecdaa..63de7a0027a 100644
--- a/test-catalog/streams/streams-scala/tests.yaml
+++ b/test-catalog/streams/streams-scala/tests.yaml
@@ -1,7 +1,3 @@
-org.apache.kafka.streams.scala.StreamToTableJoinScalaIntegrationTestImplicitSerdes:
-- testShouldCountClicksPerRegion
-- testShouldCountClicksPerRegionJava
-- testShouldCountClicksPerRegionWithNamedRepartitionTopic
org.apache.kafka.streams.scala.TopologyTest:
- shouldBuildIdenticalTopologyInJavaNScalaAggregate
- shouldBuildIdenticalTopologyInJavaNScalaCogroup
@@ -10,10 +6,6 @@ org.apache.kafka.streams.scala.TopologyTest:
- shouldBuildIdenticalTopologyInJavaNScalaProperties
- shouldBuildIdenticalTopologyInJavaNScalaSimple
- shouldBuildIdenticalTopologyInJavaNScalaTransform
-org.apache.kafka.streams.scala.WordCountTest:
-- testShouldCountWords
-- testShouldCountWordsJava
-- testShouldCountWordsMaterialized
org.apache.kafka.streams.scala.kstream.ConsumedTest:
- testCreateConsumed
- testCreateConsumedWithResetPolicy
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 39bbec5ed74..16d118d1110 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -404,385 +404,6 @@ org.apache.kafka.streams.TopologyTest:
-
timeWindowedCogroupedZeroArgCountWithTopologyConfigShouldPreserveTopologyStructure
- topologyWithDynamicRoutingShouldDescribeExtractorClass
- topologyWithStaticTopicNameExtractorShouldRespectEqualHashcodeContract
-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.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.KStreamTransformIntegrationTest:
-- shouldFlatTransform
-- shouldFlatTransformValuesWithKey
-- shouldFlatTransformValuesWithKeyWithConnectedStoreProvider
-- shouldFlatTransformValuesWithValueTransformerWithoutKey
--
shouldFlatTransformValuesWithValueTransformerWithoutKeyWithConnectedStoreProvider
-- shouldFlatTransformWithConnectedStoreProvider
-- shouldTransform
-- shouldTransformValuesWithValueTransformerWithKey
-- shouldTransformValuesWithValueTransformerWithKeyWithConnectedStoreProvider
-- shouldTransformValuesWithValueTransformerWithoutKey
-- shouldTransformValuesWithValueTransformerWithoutKeyWithConnectedStoreProvider
-- shouldTransformWithConnectedStoreProvider
-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.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:
--
shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology
-- shouldAddNamedTopologyToRunningApplicationWithEmptyInitialTopology
-- shouldAddNamedTopologyToRunningApplicationWithMultipleInitialNamedTopologies
-- shouldAddNamedTopologyToRunningApplicationWithMultipleNodes
-- shouldAddNamedTopologyToRunningApplicationWithSingleInitialNamedTopology
-- 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:
-- shouldContinueWhenProcessingExceptionOccursIfExceptionHandlerReturnsContinue
-- 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.ResetIntegrationTest:
-- shouldNotAllowToResetWhenInputTopicAbsent
-- shouldNotAllowToResetWhenIntermediateTopicAbsent
-- shouldNotAllowToResetWhenSpecifiedInternalTopicDoesNotExist
-- shouldNotAllowToResetWhenSpecifiedInternalTopicIsNotInternal
-- shouldNotAllowToResetWhileStreamsIsRunning
-- testReprocessingByDurationAfterResetWithoutIntermediateUserTopic
-- testReprocessingFromDateTimeAfterResetWithoutIntermediateUserTopic
-- testReprocessingFromFileAfterResetWithoutIntermediateUserTopic
-- testReprocessingFromScratchAfterResetWithIntermediateInternalTopic
-- testReprocessingFromScratchAfterResetWithIntermediateUserTopic
-- testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
-- testResetWhenInternalTopicsAreSpecified
-- testResetWhenLongSessionTimeoutConfiguredWithForceOption
-org.apache.kafka.streams.integration.ResetIntegrationWithSslTest:
-- testReprocessingFromScratchAfterResetWithIntermediateInternalTopic
-- testReprocessingFromScratchAfterResetWithIntermediateUserTopic
-- testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
-- testResetWhenInternalTopicsAreSpecified
-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.StreamsUncaughtExceptionHandlerIntegrationTest:
-- shouldEmitSameRecordAfterFailover
-- shouldReplaceSingleThread
-- shouldReplaceThreads
-- shouldReplaceThreadsWithoutJavaHandler
-- shouldShutDownClientIfGlobalStreamThreadWantsToReplaceThread
-- shouldShutdownClient
-- shouldShutdownMultipleThreadApplication
-- shouldShutdownSingleThreadApplication
-- shouldShutdownThreadUsingOldHandler
-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.internals.ApiUtilsTest:
- shouldContainsNameAndValueInFailMsgPrefix
- shouldReturnMillisecondsOnValidDuration
@@ -2222,8 +1843,6 @@
org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest:
- shouldThrowStreamsExceptionOnStartupIfThereIsAStreamsException
- shouldTimeOutOnGlobalConsumerInstanceId
- shouldTransitionToRunningOnStart
-org.apache.kafka.streams.processor.internals.HandlingSourceTopicDeletionIntegrationTest:
-- shouldThrowErrorAfterSourceTopicDeleted
org.apache.kafka.streams.processor.internals.HighAvailabilityStreamsPartitionAssignorTest:
-
shouldReturnAllActiveTasksToPreviousOwnerRegardlessOfBalanceAndTriggerRebalanceIfEndOffsetFetchFailsAndHighAvailabilityEnabled
- shouldScheduleProbingRebalanceOnThisClientIfWarmupTasksRequired
