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 29e7c56e9f3 Update test catalog data for GHA workflow run 27644338286
29e7c56e9f3 is described below
commit 29e7c56e9f37df3728414287a2dc148e7708e777
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jun 17 00:09:14 2026 +0000
Update test catalog data for GHA workflow run 27644338286
Commit:
https://github.com/apache/kafka/commit/18cba70a66051c9f660f72aa1efee8305bc20f41
GitHub Run: https://github.com/apache/kafka/actions/runs/27644338286
---
.../clients/clients-integration-tests/tests.yaml | 2 -
test-catalog/clients/tests.yaml | 2 +
test-catalog/core/tests.yaml | 2 -
test-catalog/group-coordinator/tests.yaml | 41 ++++++++++++++----
test-catalog/streams/tests.yaml | 50 ++++++++++++++++++++++
5 files changed, 85 insertions(+), 12 deletions(-)
diff --git a/test-catalog/clients/clients-integration-tests/tests.yaml
b/test-catalog/clients/clients-integration-tests/tests.yaml
index af4e48d2a46..dd6d46f15e9 100644
--- a/test-catalog/clients/clients-integration-tests/tests.yaml
+++ b/test-catalog/clients/clients-integration-tests/tests.yaml
@@ -263,7 +263,6 @@
org.apache.kafka.clients.consumer.PlaintextConsumerSubscriptionTest:
org.apache.kafka.clients.consumer.PlaintextConsumerTest:
- testAsyncConsumeCoordinatorFailover
- testAsyncConsumerAutoOffsetReset
-- testAsyncConsumerCloseLeavesGroupOnInterrupt
- testAsyncConsumerCloseOnBrokerShutdown
- testAsyncConsumerClusterResourceListener
- testAsyncConsumerConsumeMessagesWithCreateTime
@@ -302,7 +301,6 @@ org.apache.kafka.clients.consumer.PlaintextConsumerTest:
- testAsyncConsumerUnsubscribeDoesNotCommitOffsetsWithAutoCommitEnabled
- testAsyncStaticMemberCloseWithLeaveGroupTriggersRebalance
- testClassicConsumerAutoOffsetReset
-- testClassicConsumerCloseLeavesGroupOnInterrupt
- testClassicConsumerCloseOnBrokerShutdown
- testClassicConsumerClusterResourceListener
- testClassicConsumerConsumeMessagesWithCreateTime
diff --git a/test-catalog/clients/tests.yaml b/test-catalog/clients/tests.yaml
index ba84dd8d8ef..c71c4e9dbf8 100644
--- a/test-catalog/clients/tests.yaml
+++ b/test-catalog/clients/tests.yaml
@@ -837,6 +837,7 @@ org.apache.kafka.clients.consumer.KafkaConsumerTest:
- testBeginningOffsetsAuthenticationFailure
- testBeginningOffsetsTimeout
- testChangingRegexSubscription
+-
testClassicConsumerCloseRunsRevocationCallbackAndAttemptsLeaveGroupWhenInterrupted
- testClassicProtocolLogsRecommendationToTryConsumerProtocol
- testClientInstanceId
- testClientInstanceIdInvalidTimeout
@@ -1194,6 +1195,7 @@
org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumerTest:
- testCloseLeavesGroup
- testCloseLeavesGroupDespiteInterrupt
- testCloseLeavesGroupDespiteOnPartitionsLostError
+- testCloseRunsRevocationCallbackAndSendsLeaveGroupEventOnInterrupt
- testCloseWrapsStreamsRebalanceListenerException
- testCommitAsyncShouldCopyOffsets
- testCommitAsyncUserSuppliedCallbackNoException
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index 450ee7994e7..dc22b6039c9 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -397,8 +397,6 @@ kafka.api.PlaintextConsumerAssignorsTest:
- testRemoteAssignorInvalid
- testRemoteAssignorRange
- testRoundRobinAssignment
-kafka.api.PlaintextConsumerTest:
-- testCloseLeavesGroupOnInterrupt
kafka.api.PlaintextEndToEndAuthorizationTest:
- testListenerName
- testNoConsumeWithDescribeAclViaAssign
diff --git a/test-catalog/group-coordinator/tests.yaml
b/test-catalog/group-coordinator/tests.yaml
index 5d222862c23..1bba12af1f5 100644
--- a/test-catalog/group-coordinator/tests.yaml
+++ b/test-catalog/group-coordinator/tests.yaml
@@ -233,6 +233,7 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTest:
- testSyncGroupWithException
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTest:
- testHeartbeatArmSuppressReSolicitCycle
+- testHeartbeatDecorationFailurePreservesCommittedResponse
- testHeartbeatNeverSetsFlagWithoutPlugin
- testHeartbeatSetsTopologyDescriptionRequiredWhenStoredLags
- testHeartbeatSkipsFlagOnV0Request
@@ -240,6 +241,18 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTes
- testHeartbeatSkipsFlagWhenStaleTopologyStatusPresent
- testHeartbeatSkipsFlagWhenStoredMatchesCurrent
- testShutdownClosesPlugin
+- testUpdateBackoffArmedWhenStoredEpochWriteFailsAfterPluginSuccess
+- testUpdateGroupDisappearsBetweenPluginSuccessAndWriteDropsBackoffEntry
+- testUpdatePermanentFailurePersistsFailedEpoch
+- testUpdatePluginFutureWithNullCauseIsTreatedAsTransient
+- testUpdatePluginReturnsNullFutureIsTreatedAsPermanentFailure
+- testUpdatePreValidationFailureDoesNotArmBackoff
+- testUpdateRejectedWhenCoordinatorNotActive
+- testUpdateRejectsEmptyGroupId
+- testUpdateRejectsEmptyMemberId
+- testUpdateReturnsUnsupportedVersionWhenNoPlugin
+- testUpdateSuccessPersistsStoredEpoch
+- testUpdateTransientFailureWritesNoRecord
org.apache.kafka.coordinator.group.GroupCoordinatorShardTest:
- testCleanupGroupMetadataForConsumerGroup
- testCleanupGroupMetadataForShareGroup
@@ -721,9 +734,10 @@
org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testUpdatingSubscriptionTriggersNewTargetAssignment
- testValidHeartbeat
- testValidLeaveGroup
-- testValidateStreamsGroupMemberDoesNotSeeUncommittedFence
-- testValidateStreamsGroupMemberThrowsWhenGroupAbsent
-- testValidateStreamsGroupMemberThrowsWhenMemberAbsent
+- testValidateStreamsGroupTopologyDescriptionUpdateDoesNotSeeUncommittedFence
+- testValidateStreamsGroupTopologyDescriptionUpdateRejectsStaleEpoch
+- testValidateStreamsGroupTopologyDescriptionUpdateThrowsWhenGroupAbsent
+- testValidateStreamsGroupTopologyDescriptionUpdateThrowsWhenMemberAbsent
org.apache.kafka.coordinator.group.OffsetAndMetadataTest:
- testAttributes
- testFromRecord
@@ -876,7 +890,7 @@ org.apache.kafka.coordinator.group.UtilsTest:
- testComputeTopicHashWithLeastSignificantBitsFirst
- testNonExistingTopicName
org.apache.kafka.coordinator.group.api.streams.StreamsGroupTopologyDescriptionTest:
-- testCollectionsAreDefensivelyCopied
+- testCollectionAccessorsAreUnmodifiable
- testNodeIsSealedToSourceProcessorSink
- testNullArgumentsRejected
- testProcessorEqualsAndHashCode
@@ -1352,15 +1366,26 @@
org.apache.kafka.coordinator.group.streams.StreamsGroupTest:
- testValidateOffsetFetch
- testValidateTransactionalOffsetCommit
org.apache.kafka.coordinator.group.streams.StreamsGroupTopologyDescriptionBackoffTest:
+- testArmIfNotActiveAdvancesAttemptsAfterExpiredWindowAtSameEpoch
- testArmIfNotActiveArmsWhenIdle
-- testArmIfNotActiveDoublesAfterExpiredWindowAtSameEpoch
- testArmIfNotActiveReArmsAfterEpochAdvance
- testArmIfNotActiveReturnsFalseWhenAlreadyActive
-- testClearRemovesEntry
-- testConsecutiveArmsDoubleTheWindowUpToMax
-- testDifferentEpochResetsTheWindow
+- testArmOrExtendIsNoOpWhenStoredEpochIsNewer
+- testClearGroupRemovesEntryUnconditionally
+- testClearIsNoOpWhenEpochDoesNotMatch
+- testClearRemovesEntryWhenEpochMatches
+- testConsecutiveArmsAdvanceAttemptsUpToCap
+- testDifferentEpochResetsAttempts
- testFirstArmUsesInitialDelay
- testIsActiveIsScopedToEpoch
+- testProductionWiringUsesJitter
+org.apache.kafka.coordinator.group.streams.StreamsGroupTopologyDescriptionConverterTest:
+- testConvertsAllThreeNodeKindsAndPreservesOrder
+- testEmptyTopologyIsAccepted
+- testGlobalStoreIsConverted
+- testGlobalStoreWithMismatchedNodesIsRejected
+- testSinkWithoutTopicYieldsEmptyOptional
+- testUnknownNodeTypeIsRejected
org.apache.kafka.coordinator.group.streams.StreamsTopologyTest:
- asStreamsGroupDescribeTopicInfoShouldConvertCorrectly
- asStreamsGroupDescribeTopologyShouldReturnCorrectStructure
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 505c2fcb24e..47af2fda78c 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -3935,6 +3935,39 @@ org.apache.kafka.streams.state.ValueTimestampHeadersTest:
- shouldNotBeEqualWhenDifferentTimestamps
- shouldNotBeEqualWhenDifferentValues
- shouldReturnNullWhenValueIsNullWithMake
+org.apache.kafka.streams.state.internals.AbstractTransactionBufferTest:
+- allForwardMergesStagedAndBase
+- allReverseReturnsKeysDescending
+- allStagedTombstoneHidesBaseEntry
+- boundStagingBothBoundsExclusiveUpperReturnsSubMap
+- boundStagingBothBoundsInclusiveReturnsSubMap
+- boundStagingBothNullReturnsFullMap
+- boundStagingOnlyFromReturnsTailMap
+- boundStagingOnlyToExclusiveReturnsHeadMapExclusive
+- boundStagingOnlyToInclusiveReturnsHeadMapInclusive
+- byteCountAccumulatesAcrossMultipleStages
+- byteCountReflectsStagedTombstone
+- byteCountReflectsStagedValue
+- commitClearsPendingWritesAndBytes
+- commitFlushesTombstoneToBase
+- commitFlushesWritesToBase
+- getStagedTombstoneReturnsEmptyOptional
+- getStagedValueReturnsOptionalOfValue
+- getUnstaggedKeyReturnsNull
+- isEmptyAndZeroBytesOnFreshBuffer
+- isNotEmptyAfterStage
+- nonOwnerAllSnapshotsAtCreationTime
+- nonOwnerRangeSnapshotsAtCreationTime
+- nonOwnerThreadCanReadStagedEntry
+- rangeExclusiveUpperBound
+- rangeInclusiveUpperBound
+- rangeNullBothBoundsWithReverseReturnsSameAsAllReverse
+- rangeNullFromOpensLowerBound
+- rangeNullToOpensUpperBound
+- rollbackClearsPendingWritesAndBytes
+- rollbackDiscardsNewEntries
+- rollbackLeavesBaseUnchanged
+- subsequentBatchAfterCommitIsIndependent
org.apache.kafka.streams.state.internals.AggregationWithHeadersDeserializerTest:
- shouldDeserializeAggregationWithEmptyHeaders
- shouldDeserializeAggregationWithHeaders
@@ -6376,6 +6409,23 @@
org.apache.kafka.streams.state.internals.SessionToHeadersStoreAdapterTest:
- shouldWrapFetchWithKeyRangeIterator
- shouldWrapFindSessionsIterator
- shouldWrapFindSessionsWithKeyRangeIterator
+org.apache.kafka.streams.state.internals.StagedMergeIteratorTest:
+- shouldHandleAllTombstones
+- shouldHandleBothEmpty
+- shouldHandleConsecutiveTombstonesInStaging
+- shouldHandleEmptyBase
+- shouldHandleEmptyStaging
+- shouldMaintainSortOrderWithInterleavedEntries
+- shouldMergeDisjointStagingAndBase
+- shouldPreferStagingOverBaseForSameKey
+- shouldReverseMergeDisjointStagingAndBase
+- shouldReversePreferStagingOverBaseForSameKey
+- shouldReverseSkipBaseKeyWhenStagingHasTombstoneForSameKey
+- shouldReverseSkipTombstones
+- shouldSkipBaseKeyWhenStagingHasTombstoneForSameKey
+- shouldSkipTombstones
+- shouldSupportPeekNextKey
+- shouldThrowOnNextWhenExhausted
org.apache.kafka.streams.state.internals.StoreQueryUtilsTest:
- shouldPassIsolationLevelToReadOnlyForKeyQuery
- shouldPassIsolationLevelToReadOnlyForRangeQuery
