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 54de95d41ea Update test catalog data for GHA workflow run 28404981500
54de95d41ea is described below
commit 54de95d41eaa56f6067201e7d09c103f0f2694f7
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jun 30 01:27:15 2026 +0000
Update test catalog data for GHA workflow run 28404981500
Commit:
https://github.com/apache/kafka/commit/e0d2d650ed1ae2b68624fd8de9d9db7fa266267c
GitHub Run: https://github.com/apache/kafka/actions/runs/28404981500
---
test-catalog/core/tests.yaml | 15 +++++++++++++++
test-catalog/group-coordinator/tests.yaml | 20 ++++++++++++++++++++
test-catalog/server/tests.yaml | 19 +++++++++++++++++++
test-catalog/streams/tests.yaml | 20 ++++++++++++++++++++
4 files changed, 74 insertions(+)
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index 5c836b314cb..779d47edf97 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -2405,6 +2405,21 @@ kafka.server.share.DelayedShareFetchTest:
- testTryCompleteWhenMinBytesNotSatisfiedOnFirstFetch
- testTryCompleteWhenMinBytesNotSatisfiedOnSubsequentFetch
- testTryCompleteWhenPartitionMaxBytesStrategyThrowsException
+kafka.server.share.ReplicaManagerLogReaderTest:
+- testReadAsyncFollowsRemoteWhenTieredAndReadRemoteTrue
+- testReadAsyncResolvesPartitionsIndependently
+- testReadAsyncReturnsEmptyWhenNoPartitionsToFetch
+- testReadAsyncReturnsErrorFromLocalRead
+- testReadAsyncReturnsErrorWhenRemoteReadFails
+- testReadAsyncReturnsLocalDataWhenNotTiered
+- testReadAsyncSkipsRemoteWhenReadRemoteFalse
+- testReadRemoteCompletesExceptionallyWhenReadResultHasError
+- testReadRemoteCompletesExceptionallyWhenReadResultIsEmpty
+- testReadRemoteCompletesExceptionallyWhenRemoteLogManagerNotConfigured
+- testReadRemoteCompletesExceptionallyWhenSchedulingRejected
+- testReadRemoteCompletesWithFetchedData
+- testReadReturnsEmptyWhenNoPartitionsToFetch
+- testReadReturnsResultsFromReplicaManager
kafka.server.share.ShareCoordinatorMetadataCacheHelperImplTest:
- testConstructorThrowsErrorOnNullArgs
- testContainsTopicReturnsFalseOnException
diff --git a/test-catalog/group-coordinator/tests.yaml
b/test-catalog/group-coordinator/tests.yaml
index 061f703c587..a50196a15da 100644
--- a/test-catalog/group-coordinator/tests.yaml
+++ b/test-catalog/group-coordinator/tests.yaml
@@ -223,6 +223,7 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTest:
- testStreamsGroupDescribeCoordinatorNotActive
- testStreamsGroupDescribeInvalidGroupId
- testStreamsGroupHeartbeat
+- testStreamsGroupHeartbeatAcceptsTaskOffsetsAndWarmupTasks
- testStreamsGroupHeartbeatFailsForUnsupportedFeatures
- testStreamsGroupHeartbeatWhenNotStarted
- testStreamsGroupHeartbeatWithException
@@ -250,12 +251,18 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTes
- testDeleteGroupsSkipsPluginCallWhenNoStoredTopology
- testDeleteGroupsWithoutPluginSkipsPluginCall
- testDescribeAttachesAvailableWhenPluginReturnsTopology
+- testDescribeAvailableRecordsGetSuccessSensor
+- testDescribeConversionErrorRecordsGetErrorSensor
+- testDescribeErrorRecordsGetErrorSensor
- testDescribeFiltersNonEligibleGroupsToNotStored
- testDescribeLeavesErroredGroupsAlone
- testDescribeMarksErrorWhenPluginFails
- testDescribeMarksErrorWhenPluginThrowsSynchronously
- testDescribeMarksNotStoredWhenPluginReturnsNullDescription
+- testDescribeNullFutureRecordsGetErrorSensor
+- testDescribeNullReturnRecordsGetSuccessSensor
- testDescribeSetsNotStoredWhenNoPluginConfigured
+- testDescribeSynchronousThrowRecordsGetErrorSensor
- testDescribeWithIncludeFlagDisabledLeavesStatusDefault
- testHeartbeatArmSuppressReSolicitCycle
- testHeartbeatDecorationFailurePreservesCommittedResponse
@@ -272,6 +279,7 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTes
- testUpdateBackoffArmedWhenStoredEpochWriteFailsAfterPluginSuccess
- testUpdateGroupDisappearsBetweenPluginSuccessAndWriteDropsBackoffEntry
- testUpdatePermanentFailurePersistsFailedEpoch
+- testUpdatePermanentFailureRecordsSetErrorSensor
- testUpdatePluginFutureWithNullCauseIsTreatedAsTransient
- testUpdatePluginReturnsNullFutureIsTreatedAsPermanentFailure
- testUpdatePostPluginWriteRoutingFailureDoesNotArmBackoff
@@ -281,6 +289,8 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTes
- testUpdateRejectsEmptyMemberId
- testUpdateReturnsUnsupportedVersionWhenNoPlugin
- testUpdateSuccessPersistsStoredEpoch
+- testUpdateSuccessRecordsSetSuccessSensor
+- testUpdateTransientFailureRecordsSetErrorSensor
- testUpdateTransientFailureWritesNoRecord
org.apache.kafka.coordinator.group.GroupCoordinatorShardTest:
- testCleanupGroupMetadataDefersStreamsGroupWithStoredTopologyEpoch
@@ -722,6 +732,7 @@ org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testStreamsGroupHeartbeatPartialResponseWhenNothingChanges
- testStreamsGroupHeartbeatResponseVersion0
- testStreamsGroupHeartbeatResponseVersion1
+- testStreamsGroupHeartbeatStoresTaskOffsetsWithoutPersisting
- testStreamsGroupHeartbeatWithEmptyClassicGroup
- testStreamsGroupHeartbeatWithNonEmptyClassicGroup
- testStreamsGroupMemberCanRejoinWithEpochZero
@@ -1103,6 +1114,7 @@
org.apache.kafka.coordinator.group.metrics.GroupCoordinatorMetricsTest:
- aggregateShards
- testGlobalSensors
- testMetricNames
+- testStreamsGroupTopologyDescriptionSetAndGetSensors
org.apache.kafka.coordinator.group.modern.AssignmentTest:
- testAttributes
- testEquals
@@ -1300,6 +1312,11 @@
org.apache.kafka.coordinator.group.streams.CurrentAssignmentBuilderTest:
- testUnrevokedTasksToStable
- testUnrevokedTasksToUnreleasedTasks
- testUnrevokedTasksToUnrevokedTasks
+org.apache.kafka.coordinator.group.streams.MemberTaskOffsetsTest:
+- shouldConvertHeartbeatRequestTaskOffsets
+- shouldRetainBothMapsWhenBothListsAreNull
+- shouldUpdateTaskEndOffsetsAndRetainTaskOffsetsWhenOffsetsNull
+- shouldUpdateTaskOffsetsAndRetainTaskEndOffsetsWhenEndOffsetsNull
org.apache.kafka.coordinator.group.streams.StreamsCoordinatorRecordHelpersTest:
- testConvertToStreamsGroupTopologyRecordNullTopology
- testNewStreamsGroupCurrentAssignmentRecord
@@ -1391,12 +1408,14 @@
org.apache.kafka.coordinator.group.streams.StreamsGroupTest:
- testNoStaticMember
- testOffsetExpirationCondition
- testRemoveMember
+- testRemoveMemberClearsTaskOffsets
- testRemoveMemberRemovesCacheEntry
- testRemoveStaticMember
- testRemoveTaskProcessIds
- testSetConfiguredTopologyClearsCache
- testShutdownRequestedMethods
- testTopologyDescriptionPluginEpochs
+- testUpdateAndRetrieveTaskOffsets
- testUpdateMember
- testUpdateMemberInvalidatesCache
- testUpdatingMemberUpdatesProcessId
@@ -1449,6 +1468,7 @@
org.apache.kafka.coordinator.group.streams.TargetAssignmentBuilderTest:
- testAssignmentSwapped
- testBuildEmptyAssignmentWhenTopologyNotReady
- testCreateAssignmentMemberSpec
+- testCreateAssignmentMemberSpecPopulatesTaskOffsets
- testEmpty
- testPartialAssignmentUpdate
org.apache.kafka.coordinator.group.streams.TasksTupleTest:
diff --git a/test-catalog/server/tests.yaml b/test-catalog/server/tests.yaml
index 8ae56611586..5120ba9738f 100644
--- a/test-catalog/server/tests.yaml
+++ b/test-catalog/server/tests.yaml
@@ -542,6 +542,19 @@ org.apache.kafka.server.requests.ProduceRequestTest:
- testZSTDProduceRequest
org.apache.kafka.server.share.CachedSharePartitionTest:
- testCachedSharePartitionEqualsAndHashCode
+org.apache.kafka.server.share.dlq.ShareGroupDLQRecordFetcherTest:
+- testAsyncReadResumeCompletesEmptyWhenProcessingThrows
+- testAsyncReadResumeWithNoProgressCompletesEmpty
+- testAsyncReadResumesLoopWhenPending
+- testFetchAllRecordsInSingleRead
+- testFetchCompletesEmptyWhenReadAsyncThrows
+- testFetchRecordsAcrossMultipleReads
+- testMissingPartitionResultYieldsNoRecords
+- testNoProgressYieldsNoRecords
+- testReadErrorMidRangeReturnsRecordsReadSoFar
+- testReadErrorYieldsNoRecords
+- testRecordsBeyondEndOffsetIgnored
+- testSingleOffsetFetch
org.apache.kafka.server.share.dlq.ShareGroupDLQStateManagerTest:
- testCoalesceProduceRequestsKeepsDifferentDlqTopicsSeparate
- testCoalesceProduceRequestsMergesPartitionsForSameDlqTopic
@@ -555,10 +568,16 @@
org.apache.kafka.server.share.dlq.ShareGroupDLQStateManagerTest:
- testConstructorRejectsNullShareGroupMetrics
- testConstructorRejectsNullTime
- testConstructorRejectsNullTimer
+- testDLQRecordCopyDisabledSkipsFetch
- testDLQRecordCopyEnabled
+- testDLQRecordCopyEnabledButInvalidConfigSkipsFetch
+- testDLQRecordCopyEnabledFetchesOnceAcrossProduceRetries
- testDLQRecordCopyEnabledWithErrorOnLogRead
+- testDLQRecordCopyEnabledWithMixedLocalAndRemoteFetch
- testDLQRecordCopyEnabledWithMultipleLogReaderIterations
- testDLQRecordCopyEnabledWithPartialLogReaderRecords
+- testDLQRecordCopyEnabledWithRemoteFetch
+- testDLQRecordCopyEnabledWithRemoteFetchFailureSkipsRecords
- testDlqAfterStopFailsWithIllegalState
- testDlqBeforeStartFailsWithIllegalState
- testDlqCreateTopicFatalErrorFailsFuture
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index ed2bbbed306..0d5653b9133 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -5514,6 +5514,9 @@
org.apache.kafka.streams.state.internals.RocksDBGenericOptionsToDbOptionsColumnF
- shouldLogWarningWhenSettingWalOptions
- shouldOverwriteAllOptionsMethods
org.apache.kafka.streams.state.internals.RocksDBMigratingSessionStoreWithHeadersTest:
+- commitShouldMergePendingIntoCommittedPosition
+- committedPositionShouldExcludeStagedWritesUntilCommit
+- nonTransactionalStoreShouldUpdateCommittedPositionDirectly
- prefixScanShouldNotThrowConcurrentModificationException
- readOnlyCommittedShouldHideStagedPutWhileUncommittedExposesIt
- readOnlyCommittedShouldNotSeeStagedDelete
@@ -5522,6 +5525,8 @@
org.apache.kafka.streams.state.internals.RocksDBMigratingSessionStoreWithHeaders
- readOnlyRangeAndAllShouldRespectIsolationLevel
- readOnlyReverseRangeAndReverseAllShouldRespectIsolationLevel
- readOnlyReverseRangeShouldReturnEmptyIteratorWhenFromIsGreaterThanTo
+- rollbackShouldDiscardPendingPositionDeltas
+- rollbackShouldDiscardStagedWritesAndPendingPositionWithoutPriorCommit
-
shouldAddValueProvidersWithStatisticsToInjectedMetricsRecorderWhenRecordingLevelDebug
-
shouldAddValueProvidersWithoutStatisticsToInjectedMetricsRecorderWhenRecordingLevelInfo
- shouldAllowCustomManagedIterators
@@ -5687,6 +5692,9 @@
org.apache.kafka.streams.state.internals.RocksDBStoreCloseLeakTest:
- shouldCloseColumnFamilyHandlesWhenAccessorPutThrowsDuringClose
- shouldCloseOffsetsCfOptionsOnStoreClose
org.apache.kafka.streams.state.internals.RocksDBStoreTest:
+- commitShouldMergePendingIntoCommittedPosition
+- committedPositionShouldExcludeStagedWritesUntilCommit
+- nonTransactionalStoreShouldUpdateCommittedPositionDirectly
- prefixScanShouldNotThrowConcurrentModificationException
- readOnlyCommittedShouldHideStagedPutWhileUncommittedExposesIt
- readOnlyCommittedShouldNotSeeStagedDelete
@@ -5695,6 +5703,8 @@ org.apache.kafka.streams.state.internals.RocksDBStoreTest:
- readOnlyRangeAndAllShouldRespectIsolationLevel
- readOnlyReverseRangeAndReverseAllShouldRespectIsolationLevel
- readOnlyReverseRangeShouldReturnEmptyIteratorWhenFromIsGreaterThanTo
+- rollbackShouldDiscardPendingPositionDeltas
+- rollbackShouldDiscardStagedWritesAndPendingPositionWithoutPriorCommit
-
shouldAddValueProvidersWithStatisticsToInjectedMetricsRecorderWhenRecordingLevelDebug
-
shouldAddValueProvidersWithoutStatisticsToInjectedMetricsRecorderWhenRecordingLevelInfo
- shouldAllowCustomManagedIterators
@@ -6179,6 +6189,9 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreWi
- shouldRollSegments
- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreTest:
+- commitShouldMergePendingIntoCommittedPosition
+- committedPositionShouldExcludeStagedWritesUntilCommit
+- nonTransactionalStoreShouldUpdateCommittedPositionDirectly
- prefixScanShouldNotThrowConcurrentModificationException
- readOnlyCommittedShouldHideStagedPutWhileUncommittedExposesIt
- readOnlyCommittedShouldNotSeeStagedDelete
@@ -6187,6 +6200,8 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreTest:
- readOnlyRangeAndAllShouldRespectIsolationLevel
- readOnlyReverseRangeAndReverseAllShouldRespectIsolationLevel
- readOnlyReverseRangeShouldReturnEmptyIteratorWhenFromIsGreaterThanTo
+- rollbackShouldDiscardPendingPositionDeltas
+- rollbackShouldDiscardStagedWritesAndPendingPositionWithoutPriorCommit
-
shouldAddValueProvidersWithStatisticsToInjectedMetricsRecorderWhenRecordingLevelDebug
-
shouldAddValueProvidersWithoutStatisticsToInjectedMetricsRecorderWhenRecordingLevelInfo
- shouldAllowCustomManagedIterators
@@ -6271,6 +6286,9 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreTest:
- testRestoreWithDefaultSerdes
- testSize
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreWithHeadersTest:
+- commitShouldMergePendingIntoCommittedPosition
+- committedPositionShouldExcludeStagedWritesUntilCommit
+- nonTransactionalStoreShouldUpdateCommittedPositionDirectly
- prefixScanShouldNotThrowConcurrentModificationException
- readOnlyCommittedShouldHideStagedPutWhileUncommittedExposesIt
- readOnlyCommittedShouldNotSeeStagedDelete
@@ -6279,6 +6297,8 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreWithHeadersTest:
- readOnlyRangeAndAllShouldRespectIsolationLevel
- readOnlyReverseRangeAndReverseAllShouldRespectIsolationLevel
- readOnlyReverseRangeShouldReturnEmptyIteratorWhenFromIsGreaterThanTo
+- rollbackShouldDiscardPendingPositionDeltas
+- rollbackShouldDiscardStagedWritesAndPendingPositionWithoutPriorCommit
-
shouldAddValueProvidersWithStatisticsToInjectedMetricsRecorderWhenRecordingLevelDebug
-
shouldAddValueProvidersWithoutStatisticsToInjectedMetricsRecorderWhenRecordingLevelInfo
- shouldAllowCustomManagedIterators
