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 1e84d21ab72 Update test catalog data for GHA workflow run 23822788364
1e84d21ab72 is described below
commit 1e84d21ab724e8620174729d541606213e453f3e
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Apr 1 01:34:18 2026 +0000
Update test catalog data for GHA workflow run 23822788364
Commit:
https://github.com/apache/kafka/commit/b803e8be979175e950fea2b08ebd1561b5e4290b
GitHub Run: https://github.com/apache/kafka/actions/runs/23822788364
---
test-catalog/streams/tests.yaml | 37 +++++++++++++++++++++++++------------
1 file changed, 25 insertions(+), 12 deletions(-)
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 9e693c9f9ae..4bfd63a537d 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -2263,6 +2263,7 @@
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
- shouldCloseAllStoresEvenIfStoreThrowsException
- shouldCloseStateStoresOnStateManagerClose
- shouldCommitAndCloseLegacyStores
+- shouldCommitAndCloseLegacyStoresWithUnknownOffsetPositions
- shouldCommitGoodStoresEvenSomeThrowsException
- shouldExcludeCorruptedStoresFromDowngradeCheckpoint
- shouldFindSingleStoreForChangelog
@@ -2654,6 +2655,9 @@
org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest:
- shouldRestoreFromPositionAndCheckForCompletion
- shouldRestoreMultipleChangelogs
- shouldRestoreToLimitInStandbyState
+- shouldSeekByTimestampForWindowedStoreWithoutCheckpoint
+- shouldSeekToBeginningForNonWindowedStoreWithoutCheckpoint
+- shouldSeekToBeginningWhenBrokerReturnsNullForOffsetsForTimes
- shouldSupportUnregisterChangelogAfterCompletion
- shouldSupportUnregisterChangelogBeforeCompletion
- shouldSupportUnregisterChangelogBeforeInitialization
@@ -4316,6 +4320,7 @@
org.apache.kafka.streams.state.internals.DualColumnFamilyAccessorTest:
- shouldAddToBatchDeletesFromOldAndPutsToNew
- shouldCloseBothColumnFamilies
- shouldCommitOffsets
+- shouldCommitPosition
- shouldCreateAllIteratorForward
- shouldCreateAllIteratorReverse
- shouldCreatePrefixScanIterator
@@ -4343,6 +4348,7 @@
org.apache.kafka.streams.state.internals.DualColumnFamilyAccessorTest:
- shouldThrowProcessorStateExceptionWhenDeleteRangeFailsOnOldColumnFamily
- shouldThrowProcessorStateExceptionWhenPutFailsOnDeleteColumnFamily
- shouldThrowProcessorStateExceptionWhenPutFailsOnNewColumnFamily
+- shouldWipeCommittedOffsetsOnEmptyCommit
org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest:
- shouldAllowEntryMatchingHasNextCondition
- shouldFilterEntriesNotMatchingHasNextCondition
@@ -5198,8 +5204,8 @@
org.apache.kafka.streams.state.internals.RocksDBMigratingSessionStoreWithHeaders
- shouldHandleDeletesOnRestoreAll
- shouldHandleToggleOfEnablingBloomFilters
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldMatchPositionAfterPut
+- shouldMigrateExistingPositionFromFile
- shouldMigrateFromDefaultToHeadersAwareColumnFamily
- shouldNotAllowOpenIteratorsWhenUsingAutoManagedIterators
- shouldNotIncludeDeletedFromRangeResult
@@ -5287,15 +5293,16 @@
org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStoreTest:
- shouldFindValuesWithinRange
- shouldGetAllSegments
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldLoadSegmentsWithOldStyleColonFormattedName
- shouldLoadSegmentsWithOldStyleDateFormattedName
- shouldMatchPositionAfterPut
- shouldMeasureExpiredRecords
+- shouldMigrateExistingPositionFromFile
- shouldNotThrowWhenRestoringOnMissingHeaders
- shouldPutAndBackwardFetch
- shouldPutAndFetch
- shouldRemove
+- shouldRestoreMergedPositionFromMultipleSegmentsAfterRestart
- shouldRestoreRecordsAndConsistencyVectorMultipleTopics
- shouldRestoreRecordsAndConsistencyVectorSingleTopic
- shouldRestoreToByteStoreForActiveTask
@@ -5355,8 +5362,8 @@ org.apache.kafka.streams.state.internals.RocksDBStoreTest:
- shouldHandleDeletesOnRestoreAll
- shouldHandleToggleOfEnablingBloomFilters
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldMatchPositionAfterPut
+- shouldMigrateExistingPositionFromFile
- shouldNotAllowOpenIteratorsWhenUsingAutoManagedIterators
- shouldNotIncludeDeletedFromRangeResult
- shouldNotSetCacheInValueProvidersWhenUserProvidesPlainTableFormatConfig
@@ -5443,11 +5450,11 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithInde
- shouldGetAllBackwards
- shouldGetAllSegments
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldLoadSegmentsWithOldStyleColonFormattedName
- shouldLoadSegmentsWithOldStyleDateFormattedName
- shouldMatchPositionAfterPut
- shouldMeasureExpiredRecords
+- shouldMigrateExistingPositionFromFile
- shouldNotThrowWhenRestoringOnMissingHeaders
- shouldPutAndBackwardFetch
- shouldPutAndBackwardFetchEdgeKeyRange
@@ -5458,6 +5465,7 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithInde
- shouldPutAndFetchEdgeSingleKey
- shouldPutAndFetchWithPrefixKey
- shouldRemove
+- shouldRestoreMergedPositionFromMultipleSegmentsAfterRestart
- shouldRestoreRecordsAndConsistencyVectorMultipleTopics
- shouldRestoreRecordsAndConsistencyVectorSingleTopic
- shouldRestoreToByteStoreForActiveTask
@@ -5474,11 +5482,11 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithoutI
- shouldGetAllBackwards
- shouldGetAllSegments
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldLoadSegmentsWithOldStyleColonFormattedName
- shouldLoadSegmentsWithOldStyleDateFormattedName
- shouldMatchPositionAfterPut
- shouldMeasureExpiredRecords
+- shouldMigrateExistingPositionFromFile
- shouldNotThrowWhenRestoringOnMissingHeaders
- shouldPutAndBackwardFetch
- shouldPutAndBackwardFetchEdgeKeyRange
@@ -5489,6 +5497,7 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithoutI
- shouldPutAndFetchEdgeSingleKey
- shouldPutAndFetchWithPrefixKey
- shouldRemove
+- shouldRestoreMergedPositionFromMultipleSegmentsAfterRestart
- shouldRestoreRecordsAndConsistencyVectorMultipleTopics
- shouldRestoreRecordsAndConsistencyVectorSingleTopic
- shouldRestoreToByteStoreForActiveTask
@@ -5579,11 +5588,11 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithIndex
- shouldGetAllBackwards
- shouldGetAllSegments
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldLoadSegmentsWithOldStyleColonFormattedName
- shouldLoadSegmentsWithOldStyleDateFormattedName
- shouldMatchPositionAfterPut
- shouldMeasureExpiredRecords
+- shouldMigrateExistingPositionFromFile
- shouldNotThrowWhenRestoringOnMissingHeaders
- shouldPutAndBackwardFetch
- shouldPutAndBackwardFetchEdgeKeyRange
@@ -5594,6 +5603,7 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithIndex
- shouldPutAndFetchEdgeSingleKey
- shouldPutAndFetchWithPrefixKey
- shouldRemove
+- shouldRestoreMergedPositionFromMultipleSegmentsAfterRestart
- shouldRestoreRecordsAndConsistencyVectorMultipleTopics
- shouldRestoreRecordsAndConsistencyVectorSingleTopic
- shouldRestoreToByteStoreForActiveTask
@@ -5610,11 +5620,11 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithoutIn
- shouldGetAllBackwards
- shouldGetAllSegments
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldLoadSegmentsWithOldStyleColonFormattedName
- shouldLoadSegmentsWithOldStyleDateFormattedName
- shouldMatchPositionAfterPut
- shouldMeasureExpiredRecords
+- shouldMigrateExistingPositionFromFile
- shouldNotThrowWhenRestoringOnMissingHeaders
- shouldPutAndBackwardFetch
- shouldPutAndBackwardFetchEdgeKeyRange
@@ -5625,6 +5635,7 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithoutIn
- shouldPutAndFetchEdgeSingleKey
- shouldPutAndFetchWithPrefixKey
- shouldRemove
+- shouldRestoreMergedPositionFromMultipleSegmentsAfterRestart
- shouldRestoreRecordsAndConsistencyVectorMultipleTopics
- shouldRestoreRecordsAndConsistencyVectorSingleTopic
- shouldRestoreToByteStoreForActiveTask
@@ -5783,15 +5794,16 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreTe
- shouldFindValuesWithinRange
- shouldGetAllSegments
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldLoadSegmentsWithOldStyleColonFormattedName
- shouldLoadSegmentsWithOldStyleDateFormattedName
- shouldMatchPositionAfterPut
- shouldMeasureExpiredRecords
+- shouldMigrateExistingPositionFromFile
- shouldNotThrowWhenRestoringOnMissingHeaders
- shouldPutAndBackwardFetch
- shouldPutAndFetch
- shouldRemove
+- shouldRestoreMergedPositionFromMultipleSegmentsAfterRestart
- shouldRestoreRecordsAndConsistencyVectorMultipleTopics
- shouldRestoreRecordsAndConsistencyVectorSingleTopic
- shouldRestoreToByteStoreForActiveTask
@@ -5804,15 +5816,16 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreWi
- shouldFindValuesWithinRange
- shouldGetAllSegments
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldLoadSegmentsWithOldStyleColonFormattedName
- shouldLoadSegmentsWithOldStyleDateFormattedName
- shouldMatchPositionAfterPut
- shouldMeasureExpiredRecords
+- shouldMigrateExistingPositionFromFile
- shouldNotThrowWhenRestoringOnMissingHeaders
- shouldPutAndBackwardFetch
- shouldPutAndFetch
- shouldRemove
+- shouldRestoreMergedPositionFromMultipleSegmentsAfterRestart
- shouldRestoreRecordsAndConsistencyVectorMultipleTopics
- shouldRestoreRecordsAndConsistencyVectorSingleTopic
- shouldRestoreToByteStoreForActiveTask
@@ -5833,9 +5846,9 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreTest:
- shouldHandleDeletesOnRestoreAll
- shouldHandleToggleOfEnablingBloomFilters
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldMatchPositionAfterPut
- shouldMigrateDataFromDefaultToTimestampColumnFamily
+- shouldMigrateExistingPositionFromFile
- shouldNotAllowOpenIteratorsWhenUsingAutoManagedIterators
- shouldNotIncludeDeletedFromRangeResult
- shouldNotSetCacheInValueProvidersWhenUserProvidesPlainTableFormatConfig
@@ -5919,8 +5932,8 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreWithHeadersTest:
- shouldHandleDeletesOnRestoreAll
- shouldHandleToggleOfEnablingBloomFilters
- shouldHandleTombstoneRecords
-- shouldLoadPositionFromFile
- shouldMatchPositionAfterPut
+- shouldMigrateExistingPositionFromFile
- shouldMigrateFromPlainToHeadersAwareColumnFamily
- shouldMigrateFromTimestampedToHeadersAwareColumnFamily
- shouldNotAllowOpenIteratorsWhenUsingAutoManagedIterators
@@ -6021,7 +6034,7 @@
org.apache.kafka.streams.state.internals.RocksDBVersionedStoreTest:
- shouldGetRecordVersionsFromMultipleOldSegmentsInAscendingOrder
- shouldGetRecordVersionsFromOlderSegments
- shouldGetRecordVersionsInAscendingOrder
-- shouldLoadPositionFromFile
+- shouldMigrateExistingPositionFromFile
- shouldMoveRecordToOlderSegmentDuringPut
- shouldMoveRecordToOlderSegmentWithNullsDuringPut
- shouldNotDeleteExpired