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 29a58cec219 Update test catalog data for GHA workflow run 29328642050
29a58cec219 is described below
commit 29a58cec2195bcdf74cbbb3e114b6a96f4e99172
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jul 14 14:42:28 2026 +0000
Update test catalog data for GHA workflow run 29328642050
Commit:
https://github.com/apache/kafka/commit/c57175ea43fa7d90eb4f6b8cd47d8f9966490a0b
GitHub Run: https://github.com/apache/kafka/actions/runs/29328642050
---
test-catalog/core/tests.yaml | 9 +++++++++
test-catalog/streams/integration-tests/tests.yaml | 17 ++++++++++++++++-
test-catalog/streams/tests.yaml | 22 ++++++++++++++++++++--
test-catalog/tools/tests.yaml | 1 +
4 files changed, 46 insertions(+), 3 deletions(-)
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index 2466d436412..87e4e039b80 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -332,6 +332,7 @@ kafka.api.PlaintextAdminIntegrationTest:
- testDescribeStreamsGroups
- testDescribeStreamsGroupsForStatelessTopology
- testDescribeStreamsGroupsNotReady
+- testDescribeStreamsGroupsWithTopologyDescription
- testDescribeTopicsWithIds
- testDescribeTopicsWithNames
- testDescribeTopicsWithOptionPartitionSizeLimitPerResponse
@@ -2282,6 +2283,14 @@
kafka.server.StreamsGroupHeartbeatRequestTest$WithAssignmentBatchingDisabledTest
-
testStreamsGroupHeartbeatIsInaccessibleWhenDisabledByStaticGroupCoordinatorProtocolConfig
- testStreamsGroupHeartbeatIsInaccessibleWhenOffsetTopicNotExist
- testStreamsGroupHeartbeatWithInvalidAPIVersion
+kafka.server.StreamsGroupTopologyDescriptionNoPluginRequestTest:
+-
testHeartbeatDoesNotSolicitPushAndDescribeReturnsNotStoredWhenNoPluginConfigured
+-
testStreamsGroupTopologyDescriptionUpdateReturnsUnsupportedVersionWhenNoPluginConfigured
+kafka.server.StreamsGroupTopologyDescriptionRequestTest:
+- testDeleteGroupWithStoredTopologyDescription
+- testHeartbeatSolicitsPushAndDescribeReturnsStoredTopologyDescription
+- testStreamsGroupTopologyDescriptionUpdateValidationErrors
+- testStreamsGroupTopologyDescriptionUpdateWithInvalidApiVersion
kafka.server.SyncGroupRequestTest:
- testSyncGroupWithOldConsumerGroupProtocol
kafka.server.TierStateMachineTest:
diff --git a/test-catalog/streams/integration-tests/tests.yaml
b/test-catalog/streams/integration-tests/tests.yaml
index eee14a096ea..30543f1011b 100644
--- a/test-catalog/streams/integration-tests/tests.yaml
+++ b/test-catalog/streams/integration-tests/tests.yaml
@@ -103,9 +103,14 @@
org.apache.kafka.streams.integration.IQv2EndpointToPartitionsIntegrationTest:
- CLASSIC
- STREAMS
org.apache.kafka.streams.integration.IQv2HeadersStoreIntegrationTest:
-- shouldFailWithUnknownQueryTypeAgainstNonHeadersStore
+- shouldFailWithUnknownQueryTypeForKeyQueryAgainstNonHeadersStore
+- shouldFailWithUnknownQueryTypeForRangeQueryAgainstNonHeadersStore
- shouldHandleTimestampedKeyWithHeadersQuery
+- shouldHandleTimestampedRangeWithHeadersQuery
+- shouldNotSeeUnflushedWriteInRangeQueryWhenCachingEnabled
+- shouldReturnEmptyHeadersForTimestampedRangeWithHeadersQueryOnAdapterStore
- shouldServeCacheHitWhenCachingEnabledAndRecordNotYetFlushed
+- shouldThrowForTimestampedRangeWithHeadersQueryOnPlainSupplier
org.apache.kafka.streams.integration.IQv2IntegrationTest:
- CLASSIC
- STREAMS
@@ -492,6 +497,16 @@
org.apache.kafka.streams.integration.TimestampedWindowStoreWithHeadersTest:
- shouldPutFetchAndDelete
- shouldRestore
- shouldSetChangelogTopicProperties
+org.apache.kafka.streams.integration.TopologyDescriptionNoPluginIntegrationTest:
+- shouldRunStreamsApplicationAgainstBrokerWithoutTopologyDescriptionPlugin
+org.apache.kafka.streams.integration.TopologyDescriptionPluginExpirationIntegrationTest:
+- shouldDeleteStoredTopologyDescriptionWhenGroupExpires
+- shouldExpireGroupWithoutDeleteTopologyWhenPushPermanentlyFailed
+org.apache.kafka.streams.integration.TopologyDescriptionPluginIntegrationTest:
+- shouldInvokeDeleteTopologyOnDeleteGroups
+- shouldPushTopologyDescriptionOnlyOnceForTwoMembers
+- shouldPushTopologyDescriptionToPluginAfterJoin
+- shouldStopSolicitingPushAfterPermanentPluginFailure
org.apache.kafka.streams.integration.VersionedKeyValueStoreIntegrationTest:
- shouldAllowCustomIQv2ForCustomStoreImplementations
- shouldManualUpgradeFromNonVersionedNonTimestampedToVersioned
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index e726e307e33..43f67cb1dfc 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -5327,24 +5327,34 @@
org.apache.kafka.streams.state.internals.MeteredTimestampedKeyValueStoreTest:
- testMetrics
org.apache.kafka.streams.state.internals.MeteredTimestampedKeyValueStoreWithHeadersTest:
- shouldCommitInnerWhenCommitTimeRecords
+-
shouldDecrementOpenIteratorsTwiceWhenClosedTwiceForTimestampedRangeWithHeadersQuery
- shouldDelegateInit
- shouldDeleteFromInnerStoreAndRecordDeleteMetric
- shouldGetAllFromInnerStoreAndRecordAllMetric
- shouldGetBytesFromInnerStoreAndReturnGetMetric
- shouldGetRangeFromInnerStoreAndRecordRangeMetric
+-
shouldLeaveIteratorOpenWhenNextThrowsAndNotClosedForTimestampedRangeWithHeadersQuery
- shouldNotSetFlushListenerOnWrappedNoneCachingStore
- shouldNotSkipCacheForTimestampedKeyWithHeadersQueryByDefault
- shouldNotThrowExceptionIfSerdesCorrectlySetFromConstructorParameters
- shouldNotThrowExceptionIfSerdesCorrectlySetFromProcessorContext
- shouldPassChangelogTopicNameToStateStoreSerde
- shouldPassDefaultChangelogTopicNameToStateStoreSerdeIfLoggingDisabled
+- shouldPropagateBothBoundsAndAnyOrderForTimestampedRangeWithHeadersQuery
+- shouldPropagateFailureForTimestampedRangeWithHeadersQuery
+-
shouldPropagateLowerBoundAndDescendingOrderForTimestampedRangeWithHeadersQuery
+- shouldPropagateNoBoundsAndAnyOrderForTimestampedRangeWithHeadersQuery
- shouldPropagateSkipCacheForTimestampedKeyWithHeadersQuery
+- shouldPropagateUpperBoundAndAscendingOrderForTimestampedRangeWithHeadersQuery
- shouldPutAllToInnerStoreAndRecordPutAllMetric
- shouldPutIfAbsentAndRecordPutIfAbsentMetric
- shouldSetFlushListenerOnWrappedCachingStore
- shouldTimeIteratorDuration
- shouldTrackOldestOpenIteratorTimestamp
- shouldTrackOpenIteratorsMetric
+- shouldTrackOpenIteratorsMetricForRangeQuery
+- shouldTrackOpenIteratorsMetricForTimestampedRangeQuery
+- shouldTrackOpenIteratorsMetricForTimestampedRangeWithHeadersQuery
- shouldUseHeadersFromValueToDeserializeKeyInAll
- shouldUseHeadersFromValueToDeserializeKeyInPrefixScan
- shouldUseHeadersFromValueToDeserializeKeyInRange
@@ -6342,6 +6352,7 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreWithHeadersTest:
- shouldHandleDeletesAndPutBackOnRestoreAll
- shouldHandleDeletesOnRestoreAll
- shouldHandleKeyQuery
+- shouldHandleRangeQuery
- shouldHandleToggleOfEnablingBloomFilters
- shouldHandleTombstoneRecords
- shouldMatchPositionAfterPut
@@ -6385,7 +6396,6 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreWithHeadersTest:
- shouldReturnSameResultsForGetAndRangeWithEqualKeys
- shouldReturnSameResultsForGetAndReverseRangeWithEqualKeys
- shouldReturnUUIDsWithStringPrefix
-- shouldReturnUnknownQueryTypeForRangeQuery
- shouldReturnUnknownQueryTypeForUnsupportedQuery
- shouldReturnValueOnRange
- shouldReturnValueOnRangeKeyToNull
@@ -6662,6 +6672,7 @@
org.apache.kafka.streams.state.internals.StagedMergeIteratorTest:
- shouldSkipBaseKeyWhenStagingHasTombstoneForSameKey
- shouldSkipTombstones
- shouldSupportPeekNextKey
+- shouldThrowInvalidStateStoreExceptionOnHasNextAfterClose
- shouldThrowOnNextWhenExhausted
org.apache.kafka.streams.state.internals.StoreQueryUtilsTest:
- shouldPassIsolationLevelToReadOnlyForKeyQuery
@@ -6916,9 +6927,11 @@
org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilderTest:
- shouldWrapPlainKeyValueStoreAsTimestampStore
org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilderWithHeadersTest:
- shouldCollectExecutionInfoForTimestampedKeyWithHeadersQueryWhenRequested
+- shouldCollectExecutionInfoForTimestampedRangeWithHeadersQueryWhenRequested
- shouldCollectExecutionInfoWhenRequested
- shouldFailTimestampedKeyWithHeadersQueryForNegativeStoredTimestamp
- shouldHandleKeyQuery
+- shouldHandleRangeQuery
- shouldHandleTimestampedKeyQuery
- shouldHaveCachingAndChangeLoggingWhenBothEnabled
- shouldHaveCachingStoreWhenEnabled
@@ -6926,16 +6939,21 @@
org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilderWithHead
- shouldHaveChangeLoggingStoreWhenLoggingEnabled
- shouldHaveMeteredStoreAsOuterStore
-
shouldNotCollectExecutionInfoForTimestampedKeyWithHeadersQueryWhenNotRequested
+-
shouldNotCollectExecutionInfoForTimestampedRangeWithHeadersQueryWhenNotRequested
- shouldNotHaveChangeLoggingStoreWhenDisabled
- shouldNotThrowNullPointerIfKeySerdeIsNull
- shouldNotThrowNullPointerIfValueSerdeIsNull
- shouldNotWrapTimestampedByteStore
- shouldReflectFlushTimingForTimestampedKeyWithHeadersQueryOnAdapterStore
- shouldReflectFlushTimingForTimestampedKeyWithHeadersQueryOnPlainLegacyStore
+- shouldReturnEmptyHeadersForTimestampedRangeWithHeadersQueryOnAdapterStore
- shouldReturnEmptyPositionInitially
- shouldReturnHeadersForTimestampedKeyWithHeadersQueryOnHeaderPersistingStore
+- shouldReturnHeadersForTimestampedRangeWithHeadersQueryOnHeaderPersistingStore
+- shouldReturnIdenticalRangeResultsForNativeAndAdapterBuiltStores
- shouldReturnIdenticalResultsForNativeAndAdapterBuiltStores
-- shouldReturnUnknownQueryTypeForRangeQueryOnHeadersStore
+- shouldThrowForNegativeStoredTimestampForTimestampedRangeWithHeadersQuery
+- shouldThrowForTimestampedRangeWithHeadersQueryOnPlainLegacyStore
- shouldThrowNullPointerIfInnerIsNull
- shouldThrowNullPointerIfMetricsScopeIsNull
- shouldThrowNullPointerIfTimeIsNull
diff --git a/test-catalog/tools/tests.yaml b/test-catalog/tools/tests.yaml
index b75543f48ae..bfefe47b144 100644
--- a/test-catalog/tools/tests.yaml
+++ b/test-catalog/tools/tests.yaml
@@ -1017,6 +1017,7 @@ org.apache.kafka.tools.streams.DescribeStreamsGroupTest:
- testDescribeStreamsGroupWithMembersOption
- testDescribeStreamsGroupWithStateAndVerboseOptions
- testDescribeStreamsGroupWithStateOption
+- testDescribeStreamsGroupWithTopologyOption
- testDescribeStreamsGroupWithVerboseOption
- testDescribeWithUnrecognizedOption
- testDescribeWithoutGroupOption