This is an automated email from the ASF dual-hosted git repository.

github-actions[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 92700446763 Update test catalog data for GHA workflow run 25946999054
92700446763 is described below

commit 92700446763ed2ccaf8b13247006158d0e9982ed
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat May 16 02:58:33 2026 +0000

    Update test catalog data for GHA workflow run 25946999054
    
    Commit: 
https://github.com/apache/kafka/commit/9505119f2f1d91ed529ea549deddbcea46bc471f
    GitHub Run: https://github.com/apache/kafka/actions/runs/25946999054
---
 test-catalog/streams/tests.yaml | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 60d6e5e6da2..0480ed6b4c2 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -248,11 +248,13 @@ org.apache.kafka.streams.StreamsConfigTest:
 - shouldBeSupportNonPrefixedRestoreConsumerConfigs
 - shouldDefaultToEmptyListIfRackAwareAssignmentTagsIsNotSet
 - shouldDisableMetricCollectionForAllInternalClients
+- shouldDisableTransactionalStateStoresByDefault
 - shouldEnableAllOptimizationsWithOptimizeConfig
 - shouldEnableMetricCollectionForAllInternalClientsByDefault
 - 
shouldEnableMetricsForMainConsumerWhenConsumerPrefixDisabledMetricsPushEnabled
 - 
shouldEnableMetricsForMainConsumerWhenStreamMetricsPushDisabledButMainConsumerEnabled
 - shouldEnableSelfJoin
+- shouldEnableTransactionalStateStoresWhenConfigured
 - shouldEnsureExplicitInternalResourceNaming
 - shouldForwardCustomConfigsWithNoPrefixToAllClients
 - shouldGetClientTagsMapWhenSet
@@ -2291,6 +2293,7 @@ 
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
 - shouldLoadMissingFileAsEmptyPosition
 - shouldLogAWarningIfCheckpointThrowsAnIOException
 - shouldNotThrowTaskCorruptedExceptionAfterCheckpointing
+- shouldNotThrowTaskCorruptedWithoutCheckpointAndNonEmptyDirWhenTransactional
 - shouldNotThrowTaskCorruptedWithoutInMemoryStoreCheckpointAndNonEmptyDir
 - shouldNotWriteCheckpointForStoresWithoutChangelogTopic
 - shouldNotWriteDowngradeCheckpointOnCloseWhenUpgradeFromIsNull
@@ -2302,6 +2305,7 @@ 
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
 - shouldRegisterPersistentStores
 - shouldRegisterPersistentUnloggedStore
 - shouldReportChangelogAsSource
+- shouldReportHasCorruptedStores
 - shouldReportTaskType
 - shouldRestoreNonTimestampedStoreWithNoConverter
 - shouldRestoreStoreWithRestoreCallback
@@ -2562,6 +2566,7 @@ 
org.apache.kafka.streams.processor.internals.StandbyTaskTest:
 - shouldInitTaskTimeoutAndEventuallyThrow
 - shouldNotCommitAndThrowOnCloseDirty
 - shouldNotThrowFromStateManagerCloseInCloseDirty
+- shouldNotWipeStateDirOnDirtyCloseWithEosAndTransactionalStateStores
 - shouldPrepareRecycleSuspendedTask
 - shouldRecordRestoredRecords
 - shouldRequireSuspendingCreatedTasksBeforeClose
@@ -2658,6 +2663,8 @@ 
org.apache.kafka.streams.processor.internals.StateManagerUtilTest:
 - testCloseStateManagerClean
 - testCloseStateManagerThrowsExceptionWhenClean
 - testCloseStateManagerThrowsExceptionWhenDirty
+- testCloseStateManagerTransactionalDoesNotWipeWhenNoCorruptedStores
+- testCloseStateManagerTransactionalWipesWhenStoresAreCorrupted
 - testCloseStateManagerWithStateStoreWipeOut
 - testCloseStateManagerWithStateStoreWipeOutRethrowWrappedIOException
 - testRegisterStateStoreFailToLockStateDirectory
@@ -2720,6 +2727,7 @@ 
org.apache.kafka.streams.processor.internals.StreamTaskTest:
 - shouldBeProcessableIfAllPartitionsBuffered
 - shouldBeRecordIdlingTimeIfSuspended
 - shouldCallPunctuateOnPassedInProcessorNode
+- shouldCheckpointOnPostCommitInRunningStateWithEosAndTransactionalStateStores
 - shouldClearCommitStatusesInCloseDirty
 - shouldClearTaskTimeout
 - shouldCloseStateManagerEvenDuringFailureOnUncleanTaskClose
@@ -2738,6 +2746,7 @@ 
org.apache.kafka.streams.processor.internals.StreamTaskTest:
 - shouldLogNotReadyWhenStaleAfterThreshold
 - shouldMaybeReturnOffsetsForRepartitionTopicsForPurging
 - shouldNotAttemptToLockIfNoStores
+- shouldNotCheckpointOnPostCommitInRunningStateWithEosAndNotEnforced
 - shouldNotCommitAfterRestorationWhenExactlyOnceEnabled
 - shouldNotCommitOnCloseCreated
 - shouldNotGetOffsetsIfPrepareCommitDirty

Reply via email to