This is an automated email from the ASF dual-hosted git repository.
github-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 64bb6977b5e Update test catalog data for GHA workflow run 16418956975
64bb6977b5e is described below
commit 64bb6977b5ef111ca11814ec74e5f33b2b58b6d4
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Jul 21 17:00:31 2025 +0000
Update test catalog data for GHA workflow run 16418956975
Commit:
https://github.com/apache/kafka/commit/cdc2d957edb2551b4ace30acfc72f6853f00790b
GitHub Run: https://github.com/apache/kafka/actions/runs/16418956975
---
test-catalog/streams/tests.yaml | 29 +++++++++++++++++++++++++++++
1 file changed, 29 insertions(+)
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 0035dd48b41..7a1a5db69ae 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -487,6 +487,9 @@ org.apache.kafka.streams.TopologyTest:
-
timeWindowedCogroupedZeroArgCountWithTopologyConfigShouldPreserveTopologyStructure
- topologyWithDynamicRoutingShouldDescribeExtractorClass
- topologyWithStaticTopicNameExtractorShouldRespectEqualHashcodeContract
+org.apache.kafka.streams.errors.ExceptionHandlerUtilsTest:
+- checkDeadLetterQueueRecords
+- doNotBuildDeadLetterQueueRecordsIfNotConfigured
org.apache.kafka.streams.internals.ApiUtilsTest:
- shouldContainsNameAndValueInFailMsgPrefix
- shouldReturnMillisecondsOnValidDuration
@@ -2190,8 +2193,16 @@
org.apache.kafka.streams.processor.internals.ProcessorMetadataTest:
- shouldUpdate
- shouldUpdateCommitFlag
org.apache.kafka.streams.processor.internals.ProcessorNodeTest:
+- shouldBuildDeadLetterQueueRecordsInDefaultProcessingExceptionHandler
+- shouldBuildDeadLetterQueueRecordsInLogAndContinueProcessingExceptionHandler
+- shouldFailWithDeadLetterQueueRecords
+- shouldFailWithoutDeadLetterQueueRecords
+- shouldNotBeModifiable
- shouldNotHandleInternalExceptionsThrownDuringProcessing
-
shouldNotThrowFailedProcessingExceptionWhenProcessingExceptionHandlerRepliesWithContinue
+- shouldResumeWithDeadLetterQueueRecords
+- shouldResumeWithoutDeadLetterQueueRecords
+- shouldReturnsEmptyList
-
shouldThrowFailedProcessingExceptionWhenProcessingExceptionHandlerRepliesWithFail
-
shouldThrowFailedProcessingExceptionWhenProcessingExceptionHandlerThrowsAnException
- shouldThrowStreamsExceptionIfExceptionCaughtDuringClose
@@ -2327,10 +2338,15 @@
org.apache.kafka.streams.processor.internals.ReadOnlyTaskTest:
org.apache.kafka.streams.processor.internals.RecordCollectorTest:
- shouldAbortTxOnCloseDirtyIfEosEnabled
- shouldBroadcastToAllPartitions
+- shouldBuildDeadLetterQueueRecordsInDefaultExceptionHandler
+-
shouldBuildDeadLetterQueueRecordsInDefaultExceptionHandlerDuringDeserialization
+- shouldCallOldImplementationWithRecordContextExceptionHandler
- shouldClearOffsetsOnCloseClean
- shouldClearOffsetsOnCloseDirty
- shouldDropAllRecords
- shouldDropRecordExceptionUsingAlwaysContinueExceptionHandler
+- shouldFailWithDeadLetterQueueRecords
+- shouldFailWithoutDeadLetterQueueRecords
- shouldForwardFlushToStreamsProducer
- shouldForwardFlushToStreamsProducerEosEnabled
- shouldForwardRuntimeExceptionFromStreamPartitionerWithoutWrappingIt
@@ -2339,6 +2355,7 @@
org.apache.kafka.streams.processor.internals.RecordCollectorTest:
- shouldHaveRawDataDuringExceptionInSerialization
- shouldNotAbortTxOnCloseCleanIfEosEnabled
- shouldNotAbortTxnOnEOSCloseDirtyIfNothingSent
+- shouldNotBeModifiable
- shouldNotCallProductionExceptionHandlerOnClassCastException
- shouldNotCloseInternalProducerForEOS
- shouldNotCloseInternalProducerForNonEOS
@@ -2351,6 +2368,10 @@
org.apache.kafka.streams.processor.internals.RecordCollectorTest:
-
shouldNotThrowTaskCorruptedExceptionOnUnknownTopicOrPartitionExceptionUsingAlwaysContinueExceptionHandler
- shouldPassThroughRecordHeaderToSerializer
- shouldRecordRecordsAndBytesProduced
+- shouldResumeWithDeadLetterQueueRecords
+- shouldResumeWithoutDeadLetterQueueRecords
+- shouldRetryWithoutDeadLetterQueueRecords
+- shouldReturnsEmptyList
- shouldSendOnlyToEvenPartitions
- shouldSendToSpecificPartition
- shouldSendWithNoPartition
@@ -2392,10 +2413,18 @@
org.apache.kafka.streams.processor.internals.RecordCollectorTest:
- shouldUseDefaultPartitionerAsStreamPartitionerIsNull
- shouldUseDefaultPartitionerViaPartitions
org.apache.kafka.streams.processor.internals.RecordDeserializerTest:
+- shouldBuildDeadLetterQueueRecordsInDefaultDeserializationException
+- shouldBuildDeadLetterQueueRecordsInLogAndContinueDeserializationException
- shouldFailWhenDeserializationFailsAndExceptionHandlerReturnsNull
- shouldFailWhenDeserializationFailsAndExceptionHandlerThrows
+- shouldFailWithDeadLetterQueueRecords
+- shouldFailWithoutDeadLetterQueueRecords
+- shouldNotBeModifiable
-
shouldNotThrowStreamsExceptionWhenDeserializationFailsAndExceptionHandlerRepliesWithContinue
+- shouldResumeWithDeadLetterQueueRecords
+- shouldResumeWithoutDeadLetterQueueRecords
- shouldReturnConsumerRecordWithDeserializedValueWhenNoExceptions
+- shouldReturnsEmptyList
-
shouldThrowStreamsExceptionWhenDeserializationFailsAndExceptionHandlerRepliesWithFail
org.apache.kafka.streams.processor.internals.RecordQueueTest:
- shouldDropOnNegativeTimestamp
