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 0834810fd0a Update test catalog data for GHA workflow run 22490371365
0834810fd0a is described below
commit 0834810fd0a6dd02658c78f5b254ff09d3fe0931
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Feb 27 17:12:43 2026 +0000
Update test catalog data for GHA workflow run 22490371365
Commit:
https://github.com/apache/kafka/commit/4e97dadc8ef865559437369145cecfd7f8114a8b
GitHub Run: https://github.com/apache/kafka/actions/runs/22490371365
---
test-catalog/connect/mirror-client/tests.yaml | 2 +
test-catalog/streams/tests.yaml | 111 ++++++++++++++++++++++++++
2 files changed, 113 insertions(+)
diff --git a/test-catalog/connect/mirror-client/tests.yaml
b/test-catalog/connect/mirror-client/tests.yaml
index eea8d17edf1..f386b149611 100644
--- a/test-catalog/connect/mirror-client/tests.yaml
+++ b/test-catalog/connect/mirror-client/tests.yaml
@@ -10,6 +10,8 @@ org.apache.kafka.connect.mirror.MirrorClientTest:
- testIdentityReplicationUpstreamClusters
- testIsCheckpointTopic
- testIsHeartbeatTopic
+- testRemoteConsumerOffsets
+- testRemoteConsumerOffsetsIllegalArgs
- upstreamClustersTest
org.apache.kafka.connect.mirror.ReplicationPolicyTest:
- checkpointsTopic_shouldBeEffectedByInternalTopicSeparatorEnabled
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index f9e55b27458..56204c20f80 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -228,6 +228,9 @@ org.apache.kafka.streams.StreamsConfigTest:
- defaultSerdeShouldBeConfigured
- shouldAcceptAtLeastOnce
- shouldAcceptBuiltInMetricsLatestVersion
+- shouldAcceptDslStoreFormatCaseInsensitively
+- shouldAcceptValidDslStoreFormatDefault
+- shouldAcceptValidDslStoreFormatHeaders
- shouldAllowConfiguringProcessorWrapperWithClass
- shouldAllowConfiguringProcessorWrapperWithClassName
- shouldAllowMultipleOptimizations
@@ -325,6 +328,7 @@ org.apache.kafka.streams.StreamsConfigTest:
- shouldThrowConfigExceptionConsumerMetricsEnabledButAdminClientMetricsDisabled
-
shouldThrowConfigExceptionConsumerMetricsEnabledButMainConsumerAndAdminMetricsDisabled
-
shouldThrowConfigExceptionConsumerMetricsEnabledButMainConsumerMetricsDisabled
+- shouldThrowConfigExceptionForInvalidDslStoreFormat
- shouldThrowConfigExceptionIfAcceptableRecoveryLagIsOutsideBounds
-
shouldThrowConfigExceptionIfMaxInFlightRequestsPerConnectionIsInvalidStringIfEosV2Enabled
- shouldThrowConfigExceptionIfMaxWarmupReplicasIsOutsideBounds
@@ -358,6 +362,7 @@ org.apache.kafka.streams.StreamsConfigTest:
- shouldUseCacheMaxBytesBufferingConfigWhenOnlyDeprecatedConfigIsSet
- shouldUseCorrectDefaultsWhenNoneSpecified
- shouldUseDefaultStateStoreCacheMaxBytesConfigWhenNoConfigIsSet
+- shouldUseDefaultStoreFormatWhenNotSpecified
- shouldUseNewConfigsWhenPresent
- shouldUseNewDeserializationExceptionHandlerWhenBothConfigsAreSet
- shouldUseNewProductionExceptionHandlerWhenBothConfigsAreSet
@@ -2108,9 +2113,13 @@
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest:
- testTopicGroups
- testTopicGroupsByStateStore
org.apache.kafka.streams.processor.internals.KeyValueStoreMaterializerTest:
+- shouldBuildHeadersAwareStoreWithCachingEnabledByDefault
- shouldCreateDefaultTimestampedBuilderWithCachingAndLoggingDisabled
- shouldCreateDefaultTimestampedBuilderWithCachingDisabled
- shouldCreateDefaultTimestampedBuilderWithLoggingDisabled
+- shouldCreateHeadersAwareStoreWithLoggingDisabled
+- shouldCreateHeadersAwareStoreWithLoggingEnabledByDefault
+- shouldCreateHeadersAwareStoreWithProvidedSupplierAndLoggingEnabled
- shouldCreateTimestampedBuilderWithCachingAndLoggingEnabledByDefault
- shouldCreateTimestampedStoreWithProvidedSupplierAndCachingAndLoggingDisabled
-
shouldCreateTimestampedStoreWithProvidedSupplierAndCachingAndLoggingEnabledByDefault
@@ -4963,6 +4972,86 @@
org.apache.kafka.streams.state.internals.RocksDBGenericOptionsToDbOptionsColumnF
- shouldForwardAllDbOptionsCalls
- shouldLogWarningWhenSettingWalOptions
- shouldOverwriteAllOptionsMethods
+org.apache.kafka.streams.state.internals.RocksDBMigratingSessionStoreWithHeadersTest:
+- prefixScanShouldNotThrowConcurrentModificationException
+-
shouldAddValueProvidersWithStatisticsToInjectedMetricsRecorderWhenRecordingLevelDebug
+-
shouldAddValueProvidersWithoutStatisticsToInjectedMetricsRecorderWhenRecordingLevelInfo
+- shouldAllowCustomManagedIterators
+- shouldCallRocksDbConfigSetter
+-
shouldCloseOpenRangeIteratorsWhenStoreClosedAndThrowInvalidStateStoreOnHasNextAndNext
+- shouldCloseStatisticsWhenUserProvidesNoStatistics
+- shouldCloseStatisticsWhenUserProvidesStatistics
+- shouldDeleteFromStore
+- shouldDeleteIfSerializedValueIsNull
+- shouldHandleDeletesAndPutBackOnRestoreAll
+- shouldHandleDeletesOnRestoreAll
+- shouldHandleToggleOfEnablingBloomFilters
+- shouldHandleTombstoneRecords
+- shouldMatchPositionAfterPut
+- shouldMigrateFromDefaultToHeadersAwareColumnFamily
+- shouldNotAllowOpenIteratorsWhenUsingAutoManagedIterators
+- shouldNotIncludeDeletedFromRangeResult
+- shouldNotSetCacheInValueProvidersWhenUserProvidesPlainTableFormatConfig
+- shouldNotSetStatisticsInValueProvidersWhenUserProvidesStatistics
+- shouldNotThrowConcurrentModificationException
+- shouldNotThrowExceptionOnRestoreWhenThereIsPreExistingRocksDbFiles
+- shouldNotThrowInvalidRangeExceptionWithFromLargerThanTo
+- shouldNotThrowInvalidRangeExceptionWithNegativeFromKey
+- shouldNotThrowInvalidReverseRangeExceptionWithFromLargerThanTo
+- shouldNotThrowInvalidReverseRangeExceptionWithNegativeFromKey
+- shouldNotThrowNullPointerExceptionOnPutAllNullKey
+- shouldNotThrowNullPointerExceptionOnPutIfAbsentNullValue
+- shouldNotThrowNullPointerExceptionOnPutNullValue
+- shouldNotThrowWhenRestoringOnMissingHeaders
+- shouldOpenExistingStoreInRegularMode
+- shouldOpenNewStoreInRegularMode
+- shouldPerformAllQueriesWithCachingDisabled
+- shouldPerformRangeQueriesWithCachingDisabled
+- shouldPutAll
+- shouldPutOnlyIfAbsentValue
+- shouldPutReverseAll
+- shouldRemoveValueProvidersFromInjectedMetricsRecorderOnClose
+- shouldRequireOpenIteratorsWhenUsingCustomManagedIterators
+- shouldRestoreAll
+- 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
+- shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir
+- shouldThrowProcessorStateExceptionOnPutDeletedDir
+- shouldThrowWhenUserProvidesNewBlockBasedTableFormatConfig
+- shouldVerifyThatMetricsRecordedFromPropertiesGetMeasurementsFromRocksDB
+- shouldVerifyThatMetricsRecordedFromStatisticsGetMeasurementsFromRocksDB
+- shouldVerifyThatPropertyBasedMetricsUseValidPropertyName
+- testPutGetRange
+- testPutGetReverseRange
+- testPutGetWithDefaultSerdes
+- testPutIfAbsent
+- testRestore
+- testRestoreWithDefaultSerdes
+- testSize
org.apache.kafka.streams.state.internals.RocksDBRangeIteratorTest:
- shouldCallCloseCallbackOnClose
- shouldCloseIterator
@@ -5032,6 +5121,8 @@
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest:
- shouldThrowNullPointerExceptionOnRemoveNullKey
- testIteratorPeek
- testIteratorPeekBackward
+org.apache.kafka.streams.state.internals.RocksDBSessionStoreWithHeadersTest:
+- shouldThrowUnsupportedOperationOnQuery
org.apache.kafka.streams.state.internals.RocksDBStoreTest:
- prefixScanShouldNotThrowConcurrentModificationException
-
shouldAddValueProvidersWithStatisticsToInjectedMetricsRecorderWhenRecordingLevelDebug
@@ -5182,6 +5273,9 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithoutI
- shouldRestoreToByteStoreForStandbyTask
- shouldRollSegments
- shouldSkipAndRemoveDanglingIndex
+org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionStoreWithHeadersTest:
+- shouldThrowUnsupportedOperationOnQueryWithIndex
+- shouldThrowUnsupportedOperationOnQueryWithOutIndex
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionStoreWithIndexTest:
- shouldBackwardFetchAllSessionsWithSameRecordKey
- shouldBackwardFetchAllSessionsWithinKeyRange
@@ -5714,6 +5808,23 @@
org.apache.kafka.streams.state.internals.SessionKeySchemaTest:
- testUpperBoundWithKeyBytesLargerThanFirstTimestampByte
- testUpperBoundWithLargeTimestamps
- testUpperBoundWithZeroTimestamp
+org.apache.kafka.streams.state.internals.SessionSegmentWithHeadersTest:
+- shouldBeEqualIfIdIsEqual
+- shouldCompareSegmentIdOnly
+- shouldDeleteStateDirectoryOnDestroy
+- shouldHashOnSegmentIdOnly
+org.apache.kafka.streams.state.internals.SessionSegmentsWithHeadersTest:
+- shouldCleanupSegmentsThatHaveExpired
+- shouldClearSegmentsOnClose
+- shouldCloseAllOpenSegments
+- shouldCreateSegments
+- shouldGetCorrectSegmentString
+- shouldGetSegmentForTimestamp
+- shouldGetSegmentIdsFromTimestamp
+- shouldGetSegmentNameFromId
+- shouldGetSegmentsWithinTimeRange
+- shouldNotCreateSegmentThatIsAlreadyExpired
+- shouldOpenExistingSegments
org.apache.kafka.streams.state.internals.SessionStoreBuilderTest:
- shouldHaveCachingAndChangeLoggingWhenBothEnabled
- shouldHaveCachingStoreWhenEnabled
