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 d3ec469fdc4 Update test catalog data for GHA workflow run 30439820145
d3ec469fdc4 is described below
commit d3ec469fdc4065e268559c923050686f4a0809d6
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jul 29 15:23:45 2026 +0000
Update test catalog data for GHA workflow run 30439820145
Commit:
https://github.com/apache/kafka/commit/209a1b6e39a535453d302ca1306d24eded62bfda
GitHub Run: https://github.com/apache/kafka/actions/runs/30439820145
---
test-catalog/core/tests.yaml | 5 --
test-catalog/server/tests.yaml | 5 ++
test-catalog/streams/tests.yaml | 178 ++++++++++++++++++++++++++++++++++++++++
3 files changed, 183 insertions(+), 5 deletions(-)
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index f011437d2c2..320e03d14a8 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -948,11 +948,6 @@ kafka.network.DynamicConnectionQuotaTest:
- testDynamicListenerConnectionQuota
kafka.network.DynamicNumNetworkThreadsTest:
- testDynamicNumNetworkThreads
-kafka.network.ProcessorTest:
-- testParseRequestHeaderForProduceV0ToV2
-- testParseRequestHeaderWithDisabledApiVersion
-- testParseRequestHeaderWithUnsupportedApi
-- testParseRequestHeaderWithUnsupportedApiVersion
kafka.network.RequestConvertToJsonTest:
- testRequestDesc
- testRequestDescMetrics
diff --git a/test-catalog/server/tests.yaml b/test-catalog/server/tests.yaml
index 10417a4e04a..d41848f655f 100644
--- a/test-catalog/server/tests.yaml
+++ b/test-catalog/server/tests.yaml
@@ -1,6 +1,11 @@
org.apache.kafka.api.EndToEndClusterIdTest:
- testEndToEndWithClassicProtocol
- testEndToEndWithConsumerProtocol
+org.apache.kafka.network.ProcessorTest:
+- testParseRequestHeaderForProduceV0ToV2
+- testParseRequestHeaderWithDisabledApiVersion
+- testParseRequestHeaderWithUnsupportedApi
+- testParseRequestHeaderWithUnsupportedApiVersion
org.apache.kafka.network.RequestConvertToJsonTest:
- testAllApiVersionsResponseHandled
- testAllRequestTypesHandled
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 42c9206cade..6e26dd86905 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -5,6 +5,13 @@ org.apache.kafka.streams.AutoOffsetResetTest:
- shouldThrowExceptionOnDurationForLatestReset
- shouldThrowExceptionOnDurationForNoneReset
- twoInstancesCreatedAtTheSameTimeWithSameOptionsShouldBeEqual
+org.apache.kafka.streams.DslStoreFormatTest:
+- shouldExposeHeadersNameField
+- shouldResolveHeaders
+- shouldResolveHeadersCaseInsensitively
+- shouldResolvePlain
+- shouldResolveTimestamped
+- shouldThrowOnInvalidInput
org.apache.kafka.streams.KafkaStreamsTest:
- inMemoryStatefulTopologyShouldNotCreateStateDirectory
- shouldAddThreadWhenRunning
@@ -3931,6 +3938,16 @@
org.apache.kafka.streams.state.QueryableStoreTypesWithHeadersTest:
- shouldAcceptTimestampedWindowStoreWithHeadersForWindowStoreType
- shouldNotAcceptTimestampedKeyValueStoreWithHeadersForWindowStoreType
- shouldNotAcceptTimestampedWindowStoreWithHeadersForKeyValueStoreType
+org.apache.kafka.streams.state.SessionStoreWithHeadersContractTest:
+- shouldPreserveEmptyHeaders
+- shouldPreserveHeadersAcrossBackwardFindSessions
+- shouldPreserveHeadersAcrossFetchByKey
+- shouldPreserveHeadersAcrossFindSessions
+- shouldRemoveSessionByWindowedKey
+- shouldReturnEmptyIteratorForMissingKey
+- shouldReturnNullForMissingSession
+- shouldRoundTripAggregationAndHeadersViaPutAndFetchSession
+- shouldTreatNullAggregationAsTombstone
org.apache.kafka.streams.state.StateSerdesTest:
- shouldReturnSerdesForBuiltInKeyAndValueTypesForBuiltinTypes
- shouldSerializeAndDeserializeKeyWithHeaders
@@ -3949,16 +3966,22 @@ org.apache.kafka.streams.state.StateSerdesTest:
org.apache.kafka.streams.state.StoresTest:
- shouldBuildKeyValueStore
- shouldBuildSessionStore
+- shouldBuildSessionStoreWithHeaders
- shouldBuildTimestampedKeyValueStore
- shouldBuildTimestampedKeyValueStoreThatWrapsInMemoryKeyValueStore
- shouldBuildTimestampedKeyValueStoreThatWrapsKeyValueStore
+- shouldBuildTimestampedKeyValueStoreWithHeaders
- shouldBuildTimestampedWindowStore
- shouldBuildTimestampedWindowStoreThatWrapsInMemoryWindowStore
- shouldBuildTimestampedWindowStoreThatWrapsWindowStore
+- shouldBuildTimestampedWindowStoreWithHeaders
- shouldBuildVersionedKeyValueStore
- shouldBuildWindowStore
- shouldCreateInMemoryKeyValueStore
- shouldCreateMemoryNavigableCache
+- shouldCreatePersistentSessionStoreWithHeadersSupplier
+- shouldCreatePersistentTimestampedKeyValueStoreWithHeadersSupplier
+- shouldCreatePersistentTimestampedWindowStoreWithHeadersSupplier
- shouldCreateRocksDbSessionStore
- shouldCreateRocksDbStore
- shouldCreateRocksDbTimestampedStore
@@ -3977,12 +4000,21 @@ org.apache.kafka.streams.state.StoresTest:
- shouldThrowIfIPersistentWindowStoreRetentionPeriodIsNegative
- shouldThrowIfIPersistentWindowStoreStoreNameIsNull
- shouldThrowIfPersistentKeyValueStoreStoreNameIsNull
+- shouldThrowIfPersistentSessionStoreWithHeadersNameIsNull
+- shouldThrowIfPersistentSessionStoreWithHeadersRetentionPeriodIsNegative
- shouldThrowIfPersistentTimestampedKeyValueStoreStoreNameIsNull
+- shouldThrowIfPersistentTimestampedKeyValueStoreWithHeadersNameIsNull
+- shouldThrowIfPersistentTimestampedWindowStoreWithHeadersNameIsNull
+-
shouldThrowIfPersistentTimestampedWindowStoreWithHeadersRetentionPeriodIsNegative
+- shouldThrowIfPersistentTimestampedWindowStoreWithHeadersWindowSizeIsNegative
- shouldThrowIfPersistentVersionedKeyValueStoreHistoryRetentionIsNegative
- shouldThrowIfPersistentVersionedKeyValueStoreSegmentIntervalIsZeroOrNegative
- shouldThrowIfPersistentVersionedKeyValueStoreStoreNameIsNull
- shouldThrowIfSupplierIsNullForKeyValueStoreBuilder
- shouldThrowIfSupplierIsNullForSessionStoreBuilder
+- shouldThrowIfSupplierIsNullForSessionStoreWithHeadersBuilder
+- shouldThrowIfSupplierIsNullForTimestampedKeyValueStoreWithHeadersBuilder
+- shouldThrowIfSupplierIsNullForTimestampedWindowStoreWithHeadersBuilder
- shouldThrowIfSupplierIsNullForVersionedKeyValueStoreBuilder
- shouldThrowIfSupplierIsNullForWindowStoreBuilder
org.apache.kafka.streams.state.StreamsMetadataTest:
@@ -3993,6 +4025,24 @@ org.apache.kafka.streams.state.StreamsMetadataTest:
- shouldNotBeEqualIfDifferInStandByTopicPartitions
- shouldNotBeEqualIfDifferInTopicPartitions
- shouldNotBeEqualIfDifferStateStoreNames
+org.apache.kafka.streams.state.TimestampedKeyValueStoreWithHeadersContractTest:
+- shouldDeleteKeyAndReturnPriorValue
+- shouldPreserveEmptyHeaders
+- shouldPreserveHeadersAcrossRange
+- shouldPreserveHeadersAcrossReverseRange
+- shouldPutIfAbsentAndNotOverwriteExisting
+- shouldReturnEmptyIteratorWhenStoreIsEmpty
+- shouldReturnNullForMissingKey
+- shouldRoundTripValueTimestampAndHeadersViaPutAndGet
+- shouldTreatNullValueAsTombstone
+org.apache.kafka.streams.state.TimestampedWindowStoreWithHeadersContractTest:
+- shouldPreserveEmptyHeaders
+- shouldPreserveHeadersAcrossBackwardFetch
+- shouldPreserveHeadersAcrossBackwardFetchAll
+- shouldPreserveHeadersAcrossFetchAll
+- shouldPreserveHeadersAcrossMultipleWindows
+- shouldReturnEmptyIteratorForMissingKey
+- shouldRoundTripValueTimestampAndHeadersViaPutAndFetch
org.apache.kafka.streams.state.ValueTimestampHeadersTest:
- shouldBeEqualToItself
- shouldBeEqualWhenSameValues
@@ -5572,6 +5622,13 @@
org.apache.kafka.streams.state.internals.PlainToHeadersWindowStoreAdapterTest:
- shouldHandleWindowKeyQuerySuccessfully
- shouldHandleWindowRangeQuerySuccessfully
- shouldNotCollectExecutionInfoWhenNotRequested
+org.apache.kafka.streams.state.internals.PlainToHeadersWindowStoreIteratorAdapterTest:
+- shouldDelegateClose
+- shouldDelegatePeekNextKey
+- shouldImplementWindowStoreIteratorInterface
+- shouldPrependEmptyHeadersAndSentinelTimestampOnNext
+- shouldReturnNullValueWhenInnerValueIsNull
+- shouldReturnNullWhenInnerKeyValueIsNull
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest:
- shouldFindGlobalStores
- shouldResolveDefaultIsolationLevelAtQueryTime
@@ -5707,6 +5764,102 @@
org.apache.kafka.streams.state.internals.RocksDBMigratingSessionStoreWithHeaders
org.apache.kafka.streams.state.internals.RocksDBMigratingWindowStoreWithHeadersCloseLeakTest:
- shouldCloseAllDualColumnFamilyHandlesWhenAccessorPutThrowsDuringClose
- shouldCloseOffsetsCfOptionsOnStoreClose
+org.apache.kafka.streams.state.internals.RocksDBMigratingWindowStoreWithHeadersTest:
+- commitShouldMergePendingIntoCommittedPosition
+- committedPositionShouldExcludeStagedWritesUntilCommit
+- nonTransactionalStoreShouldUpdateCommittedPositionDirectly
+- offsetColumnFamilyWritesShouldNotLeakIntoDataIteration
+- prefixScanShouldNotThrowConcurrentModificationException
+- readOnlyCommittedShouldHideStagedPutWhileUncommittedExposesIt
+- readOnlyCommittedShouldNotSeeStagedDelete
+- readOnlyOnNonTransactionalStoreShouldBehaveIdenticallyAcrossLevels
+- readOnlyPrefixScanShouldRespectIsolationLevel
+- readOnlyRangeAndAllShouldRespectIsolationLevel
+- readOnlyReverseRangeAndReverseAllShouldRespectIsolationLevel
+- readOnlyReverseRangeShouldReturnEmptyIteratorWhenFromIsGreaterThanTo
+- rollbackShouldDiscardPendingPositionDeltas
+- rollbackShouldDiscardStagedWritesAndPendingPositionWithoutPriorCommit
+-
shouldAddValueProvidersWithStatisticsToInjectedMetricsRecorderWhenRecordingLevelDebug
+-
shouldAddValueProvidersWithoutStatisticsToInjectedMetricsRecorderWhenRecordingLevelInfo
+- shouldAllowCustomManagedIterators
+- shouldCallRocksDbConfigSetter
+-
shouldCloseOpenRangeIteratorsWhenStoreClosedAndThrowInvalidStateStoreOnHasNextAndNext
+- shouldCloseStatisticsWhenUserProvidesNoStatistics
+- shouldCloseStatisticsWhenUserProvidesStatistics
+- shouldDeleteFromStore
+- shouldDeleteIfSerializedValueIsNull
+- shouldHandleDeletesAndPutBackOnRestoreAll
+- shouldHandleDeletesOnRestoreAll
+- shouldHandleToggleOfEnablingBloomFilters
+- shouldHandleTombstoneRecords
+- shouldIterateOverBothColumnFamiliesInUpgradeMode
+- shouldMatchPositionAfterPut
+- shouldMigrateExistingPositionFromFile
+- shouldMigrateFromDefaultColumnFamilyWhenLegacyDataExists
+- shouldNotAllowOpenIteratorsWhenUsingAutoManagedIterators
+- shouldNotIncludeDeletedFromRangeResult
+- shouldNotSetCacheInValueProvidersWhenUserProvidesPlainTableFormatConfig
+- shouldNotSetStatisticsInValueProvidersWhenUserProvidesStatistics
+- shouldNotThrowConcurrentModificationException
+- shouldNotThrowExceptionOnRestoreWhenThereIsPreExistingRocksDbFiles
+- shouldNotThrowInvalidRangeExceptionWithFromLargerThanTo
+- shouldNotThrowInvalidRangeExceptionWithNegativeFromKey
+- shouldNotThrowInvalidReverseRangeExceptionWithFromLargerThanTo
+- shouldNotThrowInvalidReverseRangeExceptionWithNegativeFromKey
+- shouldNotThrowNullPointerExceptionOnPutAllNullKey
+- shouldNotThrowNullPointerExceptionOnPutIfAbsentNullValue
+- shouldNotThrowNullPointerExceptionOnPutNullValue
+- shouldNotThrowWhenRestoringOnMissingHeaders
+- shouldOpenExistingHeadersAwareStoreInRegularMode
+- shouldOpenNewStoreInRegularMode
+- shouldPerformAllQueriesWithCachingDisabled
+- shouldPerformRangeQueriesWithCachingDisabled
+- shouldPutAll
+- shouldPutOnlyIfAbsentValue
+- shouldPutReverseAll
+- shouldRemoveValueProvidersFromInjectedMetricsRecorderOnClose
+- shouldRequireOpenIteratorsWhenUsingCustomManagedIterators
+- shouldRestoreAll
+- shouldRestoreCommittedOffsetsAfterUncleanShutdownWhenEOSDisabled
+- shouldRestoreRecordsAndConsistencyVectorMultipleTopics
+- shouldRestoreRecordsAndConsistencyVectorSingleTopic
+- shouldRestoreThenDeleteOnRestoreAll
+- shouldReturnKeysWithGivenPrefix
+- shouldReturnKeysWithGivenPrefixExcludingNextKeyLargestKey
+- shouldReturnNoKeys
+- shouldReturnSameResultsForGetAndRangeWithEqualKeys
+- shouldReturnSameResultsForGetAndReverseRangeWithEqualKeys
+- shouldReturnUUIDsWithStringPrefix
+- shouldReturnValueOnRange
+- shouldReturnValueOnRangeKeyToNull
+- shouldReturnValueOnRangeNullToKey
+- shouldReturnValueOnRangeNullToNull
+- shouldReturnValueOnReverseRangeKeyToNull
+- shouldReturnValueOnReverseRangeNullToKey
+- shouldReturnValueOnReverseRangeNullToNull
+- shouldSetStatisticsInValueProvidersWhenUserProvidesNoStatistics
+- shouldThrowNullPointerExceptionOnDelete
+- shouldThrowNullPointerExceptionOnDeleteNullKey
+- shouldThrowNullPointerExceptionOnGetNullKey
+- shouldThrowNullPointerExceptionOnNullGet
+- shouldThrowNullPointerExceptionOnNullPut
+- shouldThrowNullPointerExceptionOnNullPutAll
+- shouldThrowNullPointerExceptionOnPutAllNullKey
+- shouldThrowNullPointerExceptionOnPutIfAbsentNullKey
+- shouldThrowNullPointerExceptionOnPutNullKey
+- shouldThrowOnInitWhenEOSEnabledAndPersistedStoreStatusIsInvalid
+- shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir
+- shouldThrowWhenUserProvidesNewBlockBasedTableFormatConfig
+- shouldVerifyThatMetricsRecordedFromPropertiesGetMeasurementsFromRocksDB
+- shouldVerifyThatMetricsRecordedFromStatisticsGetMeasurementsFromRocksDB
+- shouldVerifyThatPropertyBasedMetricsUseValidPropertyName
+- testPutGetRange
+- testPutGetReverseRange
+- testPutGetWithDefaultSerdes
+- testPutIfAbsent
+- testRestore
+- testRestoreWithDefaultSerdes
+- testSize
org.apache.kafka.streams.state.internals.RocksDBRangeIteratorTest:
- shouldCallCloseCallbackOnClose
- shouldCloseIterator
@@ -7137,6 +7290,31 @@
org.apache.kafka.streams.state.internals.TimestampedSegmentsWithHeadersTest:
- shouldNotRetainFailedSegmentSoRecoveryStaysRecoverable
- shouldOpenExistingSegments
- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
+org.apache.kafka.streams.state.internals.TimestampedToHeadersStoreAdapterTest:
+- shouldCollectExecutionInfoForKeyQuery
+- shouldDelegateApproximateNumEntries
+- shouldDelegateGetPosition
+- shouldDelegateIsOpen
+- shouldDelegateName
+- shouldDelegateOtherQueryTypesToStore
+- shouldDeleteAndConvertResult
+- shouldGetAndConvertToHeaderFormat
+- shouldHandleFailedKeyQuery
+- shouldHandleKeyQuery
+- shouldHandleKeyQueryWithNullResult
+- shouldHandleRangeQuery
+- shouldPutAllEntries
+- shouldPutIfAbsentAndConvertResult
+- shouldPutRawTimestampedValueToStore
+- shouldReturnNullWhenStoreReturnsNull
+- shouldReturnTrueForPersistent
+- shouldThrowIfStoreIsNotPersistent
+- shouldThrowIfStoreIsNotTimestamped
+- shouldWrapAllIterator
+- shouldWrapPrefixScanIterator
+- shouldWrapRangeIterator
+- shouldWrapReverseAllIterator
+- shouldWrapReverseRangeIterator
org.apache.kafka.streams.state.internals.TimestampedToHeadersWindowStoreAdapterTest:
- shouldCollectExecutionInfoForWindowKeyQueryWhenRequested
- shouldCollectExecutionInfoForWindowRangeQueryWhenRequested
