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 174c196c807 Update test catalog data for GHA workflow run 23272628508
174c196c807 is described below
commit 174c196c80722b3055b3919174a158cdc2f1aade
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Mar 19 02:48:51 2026 +0000
Update test catalog data for GHA workflow run 23272628508
Commit:
https://github.com/apache/kafka/commit/51fa1601c173c956eb6f3cc001288af540298fdf
GitHub Run: https://github.com/apache/kafka/actions/runs/23272628508
---
test-catalog/core/tests.yaml | 15 +++++
test-catalog/group-coordinator/tests.yaml | 1 +
test-catalog/streams/integration-tests/tests.yaml | 7 ++
test-catalog/streams/tests.yaml | 79 +++++++++++++++++++++++
test-catalog/tools/tests.yaml | 11 ++++
5 files changed, 113 insertions(+)
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index c14c1adc84c..1784df3339c 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -2679,6 +2679,21 @@ kafka.server.StreamsGroupHeartbeatRequestTest:
-
testStreamsGroupHeartbeatIsInaccessibleWhenDisabledByStaticGroupCoordinatorProtocolConfig
- testStreamsGroupHeartbeatIsInaccessibleWhenOffsetTopicNotExist
- testStreamsGroupHeartbeatWithInvalidAPIVersion
+kafka.server.StreamsGroupHeartbeatRequestTest$WithAssignmentBatchingDisabledTest:
+- testDynamicGroupConfig
+- testEmptyStreamsGroupId
+- testFencedMemberCanRejoinWithEpochZero
+- testGroupCoordinatorChange
+- testInternalTopicsCreation
+- testInvalidMemberEpoch
+- testMemberJoiningAndExpiring
+- testMemberLeaveHeartbeat
+- testStreamsGroupHeartbeatForMultipleMembers
+-
testStreamsGroupHeartbeatIsAccessibleWhenNewGroupCoordinatorIsEnabledTopicNotExistFirst
+- testStreamsGroupHeartbeatIsInaccessibleWhenDisabledByFeatureConfig
+-
testStreamsGroupHeartbeatIsInaccessibleWhenDisabledByStaticGroupCoordinatorProtocolConfig
+- testStreamsGroupHeartbeatIsInaccessibleWhenOffsetTopicNotExist
+- testStreamsGroupHeartbeatWithInvalidAPIVersion
kafka.server.StrictControllerMutationQuotaTest:
- testControllerMutationQuotaViolation
kafka.server.SyncGroupRequestTest:
diff --git a/test-catalog/group-coordinator/tests.yaml
b/test-catalog/group-coordinator/tests.yaml
index 738c9698b5a..79af23fabb6 100644
--- a/test-catalog/group-coordinator/tests.yaml
+++ b/test-catalog/group-coordinator/tests.yaml
@@ -601,6 +601,7 @@ org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testStaticMembersLeaveUnknownGroup
- testStaticMembersUnknownInstanceBatchLeaveGroup
- testStaticMembersValidBatchLeaveGroup
+- testStreamsGroupAssignmentInterval
- testStreamsGroupDeleteCancelsInitialRebalanceTimer
- testStreamsGroupDescribeBeforeAndAfterCommittingOffset
- testStreamsGroupDescribeNoErrors
diff --git a/test-catalog/streams/integration-tests/tests.yaml
b/test-catalog/streams/integration-tests/tests.yaml
index 2a2789778a0..30ec2dabd36 100644
--- a/test-catalog/streams/integration-tests/tests.yaml
+++ b/test-catalog/streams/integration-tests/tests.yaml
@@ -251,9 +251,14 @@
org.apache.kafka.streams.integration.RangeQueryIntegrationTest:
- testStoreConfig
org.apache.kafka.streams.integration.RebalanceIntegrationTest:
- shouldCommitAllTasksIfRevokedTaskTriggerPunctuation
+org.apache.kafka.streams.integration.RebalanceIntegrationTest$WithAssignmentBatchingDisabledTest:
+- shouldCommitAllTasksIfRevokedTaskTriggerPunctuation
org.apache.kafka.streams.integration.RebalanceProtocolMigrationIntegrationTest:
- shouldMigrateFromAndToStreamsRebalanceProtocol
- shouldMigrateToAndFromStreamsRebalanceProtocol
+org.apache.kafka.streams.integration.RebalanceProtocolMigrationIntegrationTest$WithAssignmentBatchingDisabledTest:
+- shouldMigrateFromAndToStreamsRebalanceProtocol
+- shouldMigrateToAndFromStreamsRebalanceProtocol
org.apache.kafka.streams.integration.RebalanceTaskClosureIntegrationTest:
- shouldClosePendingTasksToInitAfterRebalance
org.apache.kafka.streams.integration.RegexSourceIntegrationTest:
@@ -294,6 +299,8 @@
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest:
- shouldRestoreAfterJoinRestart
org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest:
- shouldWorkWithRebalance
+org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest$WithAssignmentBatchingDisabledTest:
+- shouldWorkWithRebalance
org.apache.kafka.streams.integration.StandbyTaskCreationIntegrationTest:
- shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables
- shouldNotCreateAnyStandByTasksForStateStoreWithLoggingDisabled
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index fbc60693ac5..7372d4ccf0c 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -5617,6 +5617,81 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithoutIn
- shouldRestoreToByteStoreForStandbyTask
- shouldRollSegments
- shouldSkipAndRemoveDanglingIndex
+org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowStoreWithHeadersTest:
+- shouldCollectExecutionInfoWhenRequested
+- shouldNotCollectExecutionInfoWhenNotRequested
+- shouldReturnUnknownQueryTypeForWindowKeyQuery
+- shouldReturnUnknownQueryTypeForWindowRangeQuery
+org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowStoreWithHeadersWithIndexTest:
+- shouldBackwardFetchAllInTimeRange
+-
shouldCloseOpenIteratorsWhenStoreIsClosedAndNotThrowInvalidStateStoreExceptionOnHasNext
+- shouldEarlyClosedIteratorStillGetAllRecords
+- shouldFetchAllInTimeRange
+- shouldFetchAndIterateOverExactBinaryKeys
+- shouldFetchAndIterateOverExactKeys
+- shouldGetAll
+- shouldGetAllNonDeletedRecords
+- shouldGetAllReturnTimestampOrderedRecords
+- shouldGetBackwardAll
+- shouldMatchPositionAfterPut
+- shouldMeasureExpiredRecords
+- shouldNotThrowConcurrentModificationException
+- shouldNotThrowExceptionWhenFetchRangeIsExpired
+- shouldNotThrowInvalidRangeExceptionWithNegativeFromKey
+- shouldOnlyIterateOpenSegments
+- shouldReturnNullOnWindowNotFound
+- shouldReturnSameResultsForSingleKeyFetchAndEqualKeyRangeFetch
+- shouldThrowNullPointerExceptionOnGetNullKey
+- shouldThrowNullPointerExceptionOnPutNullKey
+- testBackwardFetchRange
+- testDeleteAndUpdate
+- testFetchDuplicates
+- testFetchRange
+- testInitialLoading
+- testPutAndFetchAfter
+- testPutAndFetchBefore
+- testPutSameKeyTimestamp
+- testRangeAndSinglePointFetch
+- testRestore
+- testRolling
+- testSegmentMaintenance
+- testValueIteratorPeek
+- testWindowIteratorPeek
+org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowStoreWithHeadersWithoutIndexTest:
+- shouldBackwardFetchAllInTimeRange
+-
shouldCloseOpenIteratorsWhenStoreIsClosedAndNotThrowInvalidStateStoreExceptionOnHasNext
+- shouldEarlyClosedIteratorStillGetAllRecords
+- shouldFetchAllInTimeRange
+- shouldFetchAndIterateOverExactBinaryKeys
+- shouldFetchAndIterateOverExactKeys
+- shouldGetAll
+- shouldGetAllNonDeletedRecords
+- shouldGetAllReturnTimestampOrderedRecords
+- shouldGetBackwardAll
+- shouldMatchPositionAfterPut
+- shouldMeasureExpiredRecords
+- shouldNotThrowConcurrentModificationException
+- shouldNotThrowExceptionWhenFetchRangeIsExpired
+- shouldNotThrowInvalidRangeExceptionWithNegativeFromKey
+- shouldOnlyIterateOpenSegments
+- shouldReturnNullOnWindowNotFound
+- shouldReturnSameResultsForSingleKeyFetchAndEqualKeyRangeFetch
+- shouldThrowNullPointerExceptionOnGetNullKey
+- shouldThrowNullPointerExceptionOnPutNullKey
+- testBackwardFetchRange
+- testDeleteAndUpdate
+- testFetchDuplicates
+- testFetchRange
+- testInitialLoading
+- testPutAndFetchAfter
+- testPutAndFetchBefore
+- testPutSameKeyTimestamp
+- testRangeAndSinglePointFetch
+- testRestore
+- testRolling
+- testSegmentMaintenance
+- testValueIteratorPeek
+- testWindowIteratorPeek
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowStoreWithIndexTest:
- shouldBackwardFetchAllInTimeRange
-
shouldCloseOpenIteratorsWhenStoreIsClosedAndNotThrowInvalidStateStoreExceptionOnHasNext
@@ -6295,6 +6370,10 @@
org.apache.kafka.streams.state.internals.TimeOrderedWindowStoreTest:
- shouldThrowIfWrongStore
- shouldThrowNullPointerExceptionOnFetchNullKey
- shouldThrowNullPointerExceptionOnPutNullKey
+org.apache.kafka.streams.state.internals.TimeOrderedWindowStoreUpgradeTest:
+- shouldMigrateFromWithIndexToWithIndexAndHeaders
+- shouldMigrateFromWithoutHeadersToWithHeaders
+- shouldMigrateFromWithoutIndexToWithIndexAndHeaders
org.apache.kafka.streams.state.internals.TimestampedKeyAndJoinSideSerializerTest:
- shouldSerializeKeyWithJoinSideAsFalse
- shouldSerializeKeyWithJoinSideAsTrue
diff --git a/test-catalog/tools/tests.yaml b/test-catalog/tools/tests.yaml
index be14b1a8c35..72ddfae2cdf 100644
--- a/test-catalog/tools/tests.yaml
+++ b/test-catalog/tools/tests.yaml
@@ -227,9 +227,13 @@ org.apache.kafka.tools.DumpLogSegmentsTest:
- testBatchAndRecordMetadataOutput
- testDumpControlRecord
- testDumpEmptyIndex
+- testDumpFileWithNoDotInName
- testDumpIndexMismatches
- testDumpMetadataRecords
- testDumpMetadataSnapshot
+- testDumpProducerIdSnapshot
+- testDumpProducerIdSnapshotCorrupt
+- testDumpProducerIdSnapshotWithBatchMetadata
- testDumpRemoteLogMetadataEmpty
- testDumpRemoteLogMetadataIoException
- testDumpRemoteLogMetadataMultipleRecordsMultipleBatches
@@ -240,11 +244,18 @@ org.apache.kafka.tools.DumpLogSegmentsTest:
- testDumpRemoteLogMetadataOneRecordOneBatch
- testDumpRemoteLogMetadataWithCorruption
- testDumpTimeIndexErrors
+- testDumpTxnIndex
+- testDumpUnknownFileSuffix
+- testIndexSanityCheck
+- testInvalidDecoderClass
- testLegacyRecordBatchOutputFormat
- testOffsetsMessageParser
- testPrintDataLog
- testPrintDataLogPartialBatches
+- testPrintTrailingBytes
- testShareGroupStateMessageParser
+- testTimeIndexDumpErrorsPrintErrors
+- testTimeIndexVerifyOnly
- testTransactionLogMessageParser
org.apache.kafka.tools.EndToEndLatencyTest:
- shouldFailWhenConsumerRecordsIsEmpty
