You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gi...@apache.org on 2026/10/16 01:16:04 UTC
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 38812641649
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 e84cf74c96d Update test catalog data for GHA workflow run 38812641649
e84cf74c96d is described below
commit e84cf74c96dbb4015aa8d4b79828a3452f0edf46
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Fri Oct 16 01:15:56 2026 +0000
Update test catalog data for GHA workflow run 38812641649
Commit: https://github.com/apache/kafka/commit/b2f85364e44abfea2bb1937d894b36edae80b968
GitHub Run: https://github.com/apache/kafka/actions/runs/38812641649
---
test-catalog/streams/integration-tests/tests.yaml | 2 ++
test-catalog/streams/tests.yaml | 19 +++++++++++++++++++
2 files changed, 21 insertions(+)
diff --git a/test-catalog/streams/integration-tests/tests.yaml b/test-catalog/streams/integration-tests/tests.yaml
index fe0c0873e10..d111299ba64 100644
--- a/test-catalog/streams/integration-tests/tests.yaml
+++ b/test-catalog/streams/integration-tests/tests.yaml
@@ -14,6 +14,8 @@ org.apache.kafka.streams.integration.AtLeastOnceDeliveryMessageLossIntegrationTe
- shouldCommitOffsetsAndProduceOutputRecordsWhenProducerFailsWithMessageTooLarge
org.apache.kafka.streams.integration.ColdStartStickinessIntegrationTest:
- shouldStickToLocalStateOnColdStart
+org.apache.kafka.streams.integration.CommitTimeoutDirtyCloseIntegrationTest:
+- shouldFullyRestoreStoreAfterAbortFailsOnTimedOutCommit
org.apache.kafka.streams.integration.ConsistencyVectorIntegrationTest:
- shouldHaveSamePositionBoundActiveAndStandBy
org.apache.kafka.streams.integration.DeadLetterQueueIntegrationTest:
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 862f20c9f7f..6f701d38d9a 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -2373,6 +2373,7 @@ org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
- shouldCommitAndCloseLegacyStores
- shouldCommitAndCloseLegacyStoresWithUnknownOffsetPositions
- shouldCommitGoodStoresEvenSomeThrowsException
+- shouldConvertNextFetchToLastAppliedOffsetWhenAdvancingRestoredOffset
- shouldExcludeCorruptedStoresFromDowngradeCheckpoint
- shouldFindSingleStoreForChangelog
- shouldGetChangelogPartitionForRegisteredStore
@@ -2381,6 +2382,9 @@ org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
- shouldInitializeOffsetsFromCheckpointFileAndDeleteIfEOSEnabled
- shouldLoadMissingFileAsEmptyPosition
- shouldLogAWarningIfCheckpointThrowsAnIOException
+- shouldNoOpAdvanceRestoredOffsetWhenNextFetchIsZero
+- shouldNotAdvanceOffsetWhenAlreadyAtRestoreBoundary
+- shouldNotMoveRestoredOffsetBackwards
- shouldNotRefreshTaskDirectoryModificationTimeWhenClosingStartupTask
- shouldNotThrowTaskCorruptedExceptionAfterCheckpointing
- shouldNotThrowTaskCorruptedWithoutCheckpointAndNonEmptyDirWhenTransactional
@@ -2500,6 +2504,7 @@ org.apache.kafka.streams.processor.internals.RecordCollectorTest:
- shouldCallOldImplementationWithRecordContextExceptionHandler
- shouldClearOffsetsOnCloseClean
- shouldClearOffsetsOnCloseDirty
+- shouldClearOffsetsOnCloseDirtyIfAbortTransactionThrows
- shouldDropAllRecords
- shouldDropRecordExceptionUsingAlwaysContinueExceptionHandler
- shouldFailWithDeadLetterQueueRecords
@@ -2780,6 +2785,19 @@ org.apache.kafka.streams.processor.internals.StateRestoreCallbackAdapterTest:
- shouldPassRecordsThrough
- shouldThrowOnRestore
- shouldThrowOnRestoreAll
+org.apache.kafka.streams.processor.internals.StoreChangelogReaderCaughtUpOffsetTest:
+- shouldAccountForTrailingOffsetHolesBeforeAdvancingCaughtUpOffset
+- shouldAdvanceStandbySourceChangelogOffsetWhenPositionReachesRestoreEndOffset
+- shouldAdvertiseRestoreEndOffsetNotLivePositionWhenActiveCompletesPastEnd
+- shouldAdvertiseZeroAfterActiveRestoreOfEmptyChangelogWithZeroEndOffset
+- shouldKeepLastAppliedOffsetAfterNonEmptyActiveRestore
+- shouldNotAdvanceActiveOffsetOnEmptyPollWhileStillBehindEndOffset
+- shouldNotAdvanceActiveOffsetWhenPositionIsBehindRestoreEndOffset
+- shouldNotAdvanceStandbyOffsetOnEmptyPollWhileLagIsPositive
+- shouldNotAdvanceStandbyOffsetWhenPositionTimesOut
+- shouldNotAdvertiseBufferedSourceChangelogRecordsBeyondCommittedLimit
+- shouldReportZeroTaskLagAfterEmptyHighEndOffsetRestore
+- shouldResumeAtLogEndOffsetAfterCheckpointingEmptyHighEndOffsetRestore
org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest:
- changelogEndOffsetsShouldFallBackToStoreMetadataWhenLogicalChangelogMetadataIsNull
- logicalChangelogEndOffsetsShouldReturnNullWhenBothSourcesUnknown
@@ -2810,6 +2828,7 @@ org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest:
- shouldOnlyRestoreStandbyChangelogInUpdateStandbyState
- shouldPassSuspendReasonToStandbyListener
- shouldPollWithRightTimeout
+- shouldReportCaughtUpOffsetAfterRestoringEmptyChangelogWithHighEndOffset
- shouldRequestCommittedOffsetsAndHandleTimeoutException
- shouldRequestEndOffsetsAndHandleTimeoutException
- shouldRequestPositionAndHandleTimeoutException