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 adb2341f10e Update test catalog data for GHA workflow run 21768985833
adb2341f10e is described below

commit adb2341f10ed99f2319bf36253a6d45ec3cb3def
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Feb 7 01:25:49 2026 +0000

    Update test catalog data for GHA workflow run 21768985833
    
    Commit: 
https://github.com/apache/kafka/commit/127a644c7d6ec7117873140575bad4fc406c2bc6
    GitHub Run: https://github.com/apache/kafka/actions/runs/21768985833
---
 test-catalog/streams/integration-tests/tests.yaml | 2 ++
 test-catalog/streams/tests.yaml                   | 3 +++
 2 files changed, 5 insertions(+)

diff --git a/test-catalog/streams/integration-tests/tests.yaml 
b/test-catalog/streams/integration-tests/tests.yaml
index 7d3247185bb..c97fbd64f99 100644
--- a/test-catalog/streams/integration-tests/tests.yaml
+++ b/test-catalog/streams/integration-tests/tests.yaml
@@ -224,6 +224,8 @@ 
org.apache.kafka.streams.integration.RebalanceIntegrationTest:
 org.apache.kafka.streams.integration.RebalanceProtocolMigrationIntegrationTest:
 - shouldMigrateFromAndToStreamsRebalanceProtocol
 - shouldMigrateToAndFromStreamsRebalanceProtocol
+org.apache.kafka.streams.integration.RebalanceTaskClosureIntegrationTest:
+- shouldClosePendingTasksToInitAfterRebalance
 org.apache.kafka.streams.integration.RegexSourceIntegrationTest:
 - shouldAddStateStoreToRegexDefinedSource
 - shouldNotCrashIfPatternMatchesTopicHasNoData
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 7b59b8d120c..d8422d7e9d0 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -3038,6 +3038,7 @@ 
org.apache.kafka.streams.processor.internals.TaskManagerTest:
 - shouldCloseCleanWhenRemoveAllActiveTasksFromStateUpdaterOnPartitionLost
 - shouldCloseDirtyActiveUnassignedTasksWhenErrorCleanClosingTask
 - shouldCloseDirtyWhenRemoveFailedActiveTasksFromStateUpdaterOnPartitionLost
+- shouldClosePendingTasksToInitDuringShutdown
 - shouldCloseStandbyTasksOnShutdown
 - shouldCloseStandbyUnassignedTasksWhenCreatingNewTasks
 - shouldCloseTasksIfStateUpdaterTimesOutOnRemove
@@ -3188,7 +3189,9 @@ org.apache.kafka.streams.processor.internals.TasksTest:
 - shouldDrainPendingTasksToCreate
 - shouldKeepAddedTasks
 - shouldRemoveFailedTask
+- shouldRemovePendingTaskToClose
 - shouldVerifyIfPendingActiveTaskToInitAreDrained
+- shouldVerifyIfPendingStandbyTaskToInitAreDrained
 - shouldVerifyIfPendingTaskToInitExist
 org.apache.kafka.streams.processor.internals.ThreadMetadataImplTest:
 - shouldBeEqualIfSameObject

Reply via email to