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 29fbe54bba4 Update test catalog data for GHA workflow run 30182835036
29fbe54bba4 is described below
commit 29fbe54bba45a181367e9aebd08b1047257635e8
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sun Jul 26 06:34:11 2026 +0000
Update test catalog data for GHA workflow run 30182835036
Commit:
https://github.com/apache/kafka/commit/34e04e35e057b22ec6b43d3ffbc73c037b7ce093
GitHub Run: https://github.com/apache/kafka/actions/runs/30182835036
---
test-catalog/clients/tests.yaml | 2 ++
test-catalog/core/tests.yaml | 2 ++
test-catalog/group-coordinator/tests.yaml | 8 ++++++++
test-catalog/streams/tests.yaml | 14 +++++++++++++-
test-catalog/tools/tests.yaml | 5 -----
5 files changed, 25 insertions(+), 6 deletions(-)
diff --git a/test-catalog/clients/tests.yaml b/test-catalog/clients/tests.yaml
index 7c26368d2ca..337ebff779f 100644
--- a/test-catalog/clients/tests.yaml
+++ b/test-catalog/clients/tests.yaml
@@ -2579,8 +2579,10 @@
org.apache.kafka.clients.consumer.internals.StreamsGroupHeartbeatRequestManagerT
- testMaximumTimeToWaitSelectingMinimumWaitTime
- testMaximumTimeToWaitWhenHeartbeatShouldBeNotSentImmediately
- testMaximumTimeToWaitWhenHeartbeatShouldBeSentImmediately
+- testMissingClientTagsStatusLogsWarningOnlyOnce
- testNoHeartbeatIfCoordinatorUnknown
- testNoHeartbeatIfHeartbeatSkipped
+- testNoWarningWhenClientTagsPresent
- testNotCoordinatorAndCoordinatorNotAvailableErrorResponse
- testNotSendingHeartbeatIfHeartbeatCannotBeSent
- testNotSendingHeartbeatIfMemberIsJoiningOrAcknowledgingWhenHeartbeatInFlight
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index 44e2ba28b87..0ccb23f3f70 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -2224,6 +2224,7 @@ kafka.server.StreamsGroupDescribeRequestTest:
- testStreamsGroupDescribeGroupsWithNewGroupCoordinator
- testStreamsGroupDescribeWhenFeatureFlagNotEnabled
kafka.server.StreamsGroupHeartbeatRequestTest:
+- testAlterRackAwareAssignmentTagsGroupConfig
- testDynamicGroupConfig
- testEmptyStreamsGroupId
- testFencedMemberCanRejoinWithEpochZero
@@ -2239,6 +2240,7 @@ kafka.server.StreamsGroupHeartbeatRequestTest:
- testStreamsGroupHeartbeatIsInaccessibleWhenOffsetTopicNotExist
- testStreamsGroupHeartbeatWithInvalidAPIVersion
kafka.server.StreamsGroupHeartbeatRequestTest$WithAssignmentBatchingDisabledTest:
+- testAlterRackAwareAssignmentTagsGroupConfig
- testDynamicGroupConfig
- testEmptyStreamsGroupId
- testFencedMemberCanRejoinWithEpochZero
diff --git a/test-catalog/group-coordinator/tests.yaml
b/test-catalog/group-coordinator/tests.yaml
index 051427b9de6..d666ca4000e 100644
--- a/test-catalog/group-coordinator/tests.yaml
+++ b/test-catalog/group-coordinator/tests.yaml
@@ -30,6 +30,7 @@ org.apache.kafka.coordinator.group.GroupConfigTest:
- testInvalidConfigName
- testInvalidProps
- testNotValidatedWhenNotConfigured
+- testStreamsRackAwareAssignmentTagsValidation
- testValidShareAutoOffsetResetValues
- testValidShareIsolationLevelValues
- testValidateWithAllGroupTypeConfigs
@@ -498,6 +499,7 @@ org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testGenerateRecordsOnNewClassicGroupFailureTransformsError
- testGenerationIdIncrementsOnRebalance
- testGetDifferentStaticMemberIdAfterEachRejoin
+- testGroupConfigOverridesBrokerRackAwareAssignmentTags
- testGroupEpochBumpWhenNewStaticMemberJoins
- testGroupIdsByTopics
- testGroupStuckInRebalanceTimeoutDueToNonjoinedStaticMember
@@ -577,6 +579,9 @@ org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testMemberIdGeneration
- testMemberJoinsEmptyConsumerGroup
- testMemberJoinsEmptyStreamsGroup
+- testMissingClientTagsStatusNotReturnedToVersion0Clients
+- testMissingClientTagsStatusReportsOnlyMissingTags
+- testMissingClientTagsStatusWhenRackAwareTagsConfigured
- testNewJoiningMemberTriggersNewTargetAssignment
- testNewMemberFailureAfterJoinGroupCompletion
- testNewMemberIsRejectedWithMaximumMembersIsReached
@@ -587,6 +592,8 @@ org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testNewStaticMemberIsRejectedWhenConsumerGroupIsFull
- testNoConversionWhenSizeExceedsClassicMaxGroupSize
- testNoGroupEpochBumpWhenStaticMemberTemporarilyLeaves
+- testNoMissingClientTagsStatusWhenAllTagsPresent
+- testNoMissingClientTagsStatusWhenRackAwareTagsNotConfigured
- testOnLoaded
- testOnLoadedExceedGroupMaxSizeTriggersRebalance
- testOnLoadedSchedulesClassicGroupMemberHeartbeats
@@ -599,6 +606,7 @@ org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testPartitionAssignorExceptionOnRegularHeartbeat
- testPendingMemberBatchLeaveGroup
- testPendingMembersLeaveGroup
+- testRackAwareAssignmentTagsRejectsEmptyTags
- testRebalanceCompletesBeforeMemberJoins
- testRebalanceDoesNotTimeOutWhenAllSyncAreReceived
- testRebalanceTimeoutExpiration
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 0f2bc99d0f0..3e8139c34c0 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -37,6 +37,8 @@ org.apache.kafka.streams.KafkaStreamsTest:
- shouldNotReturnDeadThreads
- shouldNotSetGlobalRestoreListenerAfterStarting
- shouldNotTriggerRecordingOfRocksDBMetricsIfRecordingLevelIsInfo
+- shouldPropagatePartitionerAndHeadersToStreamsMetadataState
+- shouldPropagateSerializerAndHeadersToStreamsMetadataState
- shouldRemoveThread
- shouldReturnAdminInstanceID
- shouldReturnEmptyLocalStorePartitionLags
@@ -1331,6 +1333,7 @@ org.apache.kafka.streams.kstream.internals.KTableImplTest:
- testStateStore
- testStateStoreLazyEval
org.apache.kafka.streams.kstream.internals.KTableKTableForeignKeyJoinScenarioTest:
+- shouldPropagateHeadersToCustomForeignKeyJoinPartitioners
- shouldUseExpectedTopicsWithSerde
- shouldWorkWithCompositeKeyAndBiFunctionExtractor
- shouldWorkWithCompositeKeyAndProducerIdInValue
@@ -1563,7 +1566,8 @@
org.apache.kafka.streams.kstream.internals.UnlimitedWindowTest:
- cannotCompareUnlimitedWindowWithDifferentWindowType
- shouldAlwaysOverlap
org.apache.kafka.streams.kstream.internals.WindowedStreamPartitionerTest:
-- testCopartitioning
+- shouldThrowUnsupportedOperationExceptionForDeprecatedMethod
+- testCopartitioningWithHeaders
org.apache.kafka.streams.kstream.internals.foreignkeyjoin.CombinedKeySchemaTest:
- nonNullPrimaryKeySerdeTest
- nullForeignKeySerdeTest
@@ -1879,6 +1883,10 @@
org.apache.kafka.streams.processor.internals.DefaultStateUpdaterTest:
- shouldUpdateSingleStandbyTask
- shouldUpdateStandbyTaskAfterAllActiveStatefulTasksFailed
- shouldUpdateStandbyTaskAfterAllActiveStatefulTasksRemoved
+org.apache.kafka.streams.processor.internals.DefaultStreamPartitionerTest:
+- shouldPropagateHeadersToSerializer
+- shouldReturnEmptyOptionalWhenSerializedKeyIsNull
+- shouldThrowUnsupportedOperationExceptionForDeprecatedMethod
org.apache.kafka.streams.processor.internals.DefaultStreamsRebalanceListenerTest:
- testOnAllTasksLost
- testOnAllTasksLostRecordsMetrics
@@ -2458,6 +2466,7 @@
org.apache.kafka.streams.processor.internals.RecordCollectorTest:
-
shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler
-
shouldNotThrowTaskCorruptedExceptionOnUnknownTopicOrPartitionExceptionUsingAlwaysContinueExceptionHandler
- shouldPassThroughRecordHeaderToSerializer
+- shouldPropagateHeadersToPartitioner
- shouldRecordRecordsAndBytesProduced
- shouldResumeWithDeadLetterQueueRecords
- shouldResumeWithoutDeadLetterQueueRecords
@@ -2973,10 +2982,12 @@
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest:
- shouldHaveGlobalStoreInAllMetadata
- shouldNotReturnMutableReferenceToInternalAllMetadataCollection
- shouldNotThrowExceptionWhenOnChangeNotCalled
+- shouldPropagateHeadersToPartitioner
- shouldReturnAllMetadataThatRemainsValidAfterChange
- shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist
- shouldReturnNotAvailableWhenClusterIsEmpty
- shouldReturnNullOnGetWithKeyWhenStoreDoesntExist
+- shouldThrowIfHeadersIsNull
- shouldThrowIfStoreNameIsNull
- shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore
- shouldThrowIfStreamPartitionerIsNull
@@ -5369,6 +5380,7 @@
org.apache.kafka.streams.state.internals.MeteredTimestampedKeyValueStoreWithHead
- shouldPropagateUpperBoundAndAscendingOrderForTimestampedRangeWithHeadersQuery
- shouldPutAllToInnerStoreAndRecordPutAllMetric
- shouldPutIfAbsentAndRecordPutIfAbsentMetric
+- shouldReturnRightEntriesForHeaderDependentSerdeInPrefixScan
- shouldSetFlushListenerOnWrappedCachingStore
- shouldTimeIteratorDuration
- shouldTrackOldestOpenIteratorTimestamp
diff --git a/test-catalog/tools/tests.yaml b/test-catalog/tools/tests.yaml
index fc7883fa419..c1e1219deb8 100644
--- a/test-catalog/tools/tests.yaml
+++ b/test-catalog/tools/tests.yaml
@@ -540,11 +540,6 @@ org.apache.kafka.tools.ResetIntegrationTest:
- testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
- testResetWhenInternalTopicsAreSpecified
- testResetWhenLongSessionTimeoutConfiguredWithForceOption
-org.apache.kafka.tools.ResetIntegrationWithSslTest:
-- testReprocessingFromScratchAfterResetWithIntermediateInternalTopic
-- testReprocessingFromScratchAfterResetWithIntermediateUserTopic
-- testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
-- testResetWhenInternalTopicsAreSpecified
org.apache.kafka.tools.ShareConsumerPerformanceTest:
- testBootstrapServerNotPresent
- testClientIdOverride
