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 738ad9c5575 Update test catalog data for GHA workflow run 11921355595
738ad9c5575 is described below
commit 738ad9c5575ffaef01a6974c25040b048caae573
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Nov 20 00:29:52 2024 +0000
Update test catalog data for GHA workflow run 11921355595
Commit:
https://github.com/apache/kafka/commit/441a6d0b790f4a17b454caeea7588a6b90fbd9db
GitHub Run: https://github.com/apache/kafka/actions/runs/11921355595
---
test-catalog/clients/tests.yaml | 13 ++++
test-catalog/core/tests.yaml | 65 ++++++++++++++++++++
test-catalog/metadata/tests.yaml | 13 ++++
test-catalog/streams/integration-tests/tests.yaml | 3 +
test-catalog/streams/tests.yaml | 75 +++++++++++++++++++++++
5 files changed, 169 insertions(+)
diff --git a/test-catalog/clients/tests.yaml b/test-catalog/clients/tests.yaml
index de1c70a5dc8..2d147d75a51 100644
--- a/test-catalog/clients/tests.yaml
+++ b/test-catalog/clients/tests.yaml
@@ -3034,10 +3034,20 @@ org.apache.kafka.common.internals.PartitionStatesTest:
- testUpdateAndMoveToEnd
org.apache.kafka.common.internals.SecurityManagerCompatibilityTest:
- testCompositeStrategyCallAsWhenSecurityManagerUnsupported
+- testCompositeStrategyCurrentWhenSecurityManagerUnsupported
+- testCompositeStrategyDoPrivilegedWhenSecurityManagerUnsupported
+- testCompositeStrategyLoadable
+- testCompositeStrategyLoadableWhenSecurityManagerRemoved
- testDefaultStrategyCallAsCurrent
+- testDefaultStrategyCallAsReturn
- testDefaultStrategyCurrentNull
- testDefaultStrategyDoPrivilegedReturn
+- testDefaultStrategyDoPrivilegedThrow
+- testDefaultStrategyLoadable
+- testLegacyStrategyCallAsThrowsWhenSecurityManagerUnsupported
+- testLegacyStrategyCurrentThrowsWhenSecurityManagerUnsupported
- testLegacyStrategyThrowsWhenSecurityManagerRemoved
+- testModernStrategyLoadable
- testModernStrategyLoadableWhenSecurityManagerRemoved
org.apache.kafka.common.internals.TopicTest:
- shouldAcceptValidTopicNames
@@ -4622,17 +4632,20 @@ org.apache.kafka.common.utils.ByteBufferUnmapperTest:
org.apache.kafka.common.utils.ByteUtilsTest:
- testCorrectnessReadUnsignedVarint
- testCorrectnessWriteUnsignedVarint
+- testDouble
- testInvalidVarint
- testInvalidVarlong
- testReadInt
- testReadUnsignedInt
- testReadUnsignedIntLEFromArray
+- testReadUnsignedIntLEFromInputStream
- testSizeOfUnsignedVarint
- testSizeOfVarlong
- testUnsignedVarintSerde
- testVarintSerde
- testVarlongSerde
- testWriteUnsignedIntLEToArray
+- testWriteUnsignedIntLEToOutputStream
org.apache.kafka.common.utils.BytesTest:
- testIncrement
- testIncrementUpperBoundary
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index 1970215bf21..b75fb303e99 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -337,6 +337,7 @@ kafka.api.ConsumerBounceTest:
- testClose
- testCloseDuringRebalance
- testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize
+- testConsumptionWithBrokerFailures
- testSeekAndCommitWithBrokerFailures
- testSubscribeWhenTopicUnavailable
kafka.api.ConsumerRebootstrapTest:
@@ -2064,31 +2065,69 @@ kafka.network.RequestConvertToJsonTest:
- testRequestHeaderNode
- testRequestHeaderNodeWithDeprecatedApiVersion
kafka.network.SocketServerTest:
+- closingChannelSendFailure
+- closingChannelWithBufferedReceivesFailedSend
+- closingChannelWithCompleteAndIncompleteBufferedReceives
+- configureNewConnectionException
- controlThrowable
+- idleExpiryWithBufferedReceives
+- pollException
+- processCompletedReceiveException
+- processCompletedSendException
+- processDisconnectedException
+- processNewResponseException
- remoteCloseSendFailure
+- remoteCloseWithBufferedReceives
- remoteCloseWithBufferedReceivesFailedSend
+- remoteCloseWithCompleteAndIncompleteBufferedReceives
+- remoteCloseWithIncompleteBufferedReceive
+- sendCancelledKeyException
- simpleRequest
+- testAcceptorStartOpensPortIfNeeded
- testAuthorizerFailureCausesEnableRequestProcessingFailure
- testBrokerSendAfterChannelClosedUpdatesRequestMetrics
- testClientDisconnectionUpdatesRequestMetrics
- testClientDisconnectionWithOutstandingReceivesProcessedUntilFailedSend
+- testClientInformationWithLatestApiVersionsRequest
- testClientInformationWithOldestApiVersionsRequest
- testConnectionDisconnectListenerInvokedOnClose
- testConnectionId
- testConnectionIdReuse
+- testConnectionRateLimit
+- testConnectionRatePerIp
+- testControlPlaneAsPrivilegedListener
- testControlPlaneTakePrecedenceOverInterBrokerListenerAsPrivilegedListener
+- testDisabledRequestIsRejected
- testExceptionInAcceptor
+- testFailedAcceptorStartupCausesEnableRequestProcessingFailure
- testGracefulClose
- testIdleConnection
+- testInterBrokerListenerAsPrivilegedListener
- testLatencyWithBufferedDataAndNoSocketData
+- testListenBacklogSize
- testMaxConnectionsPerIp
+- testMaxConnectionsPerIpOverrides
+- testMetricCollectionAfterShutdown
- testNoOpAction
+- testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone
+- testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress
- testProcessorMetricsTags
- testRequestMetricsAfterStop
- testRequestPerSecAndDeprecatedRequestsPerSecMetrics
- testSaslReauthenticationFailureNoKip152SaslAuthenticate
+- testSaslReauthenticationFailureWithKip152SaslAuthenticate
- testSendActionResponseWithThrottledChannelWhereThrottlingAlreadyDone
- testSendActionResponseWithThrottledChannelWhereThrottlingInProgress
+- testServerShutdownWithoutEnable
+- testSessionPrincipal
+- testSocketsCloseOnShutdown
+- testSslSocketServer
+- testStagedListenerShutdownWhenConnectionQueueIsFull
+- testStagedListenerStartup
+- testThrottledSocketsClosedOnShutdown
+- testUnmuteChannelWithBufferedReceives
+- testZeroMaxConnectionsPerIp
+- tooBigRequestIsRejected
kafka.raft.KafkaMetadataLogTest:
- testAdvanceLogStartOffsetAfterCleaning
- testCleanupOlderSnapshots
@@ -2219,8 +2258,33 @@ kafka.server.AbstractFetcherThreadTest:
- testUnknownLeaderEpochInTruncation
- testUnknownLeaderEpochWhileFetching
kafka.server.AbstractFetcherThreadWithIbp26Test:
+- testConsumerLagRemovedWithPartition
+- testCorruptMessage
+- testDelay
+- testDivergingEpochs
+- testFencedFetch
+- testFencedOffsetResetAfterOutOfRange
+- testFencedTruncation
+- testFetcherThreadHandlingPartitionFailureDuringAppending
+- testFetcherThreadHandlingPartitionFailureDuringTruncation
+- testFollowerFetchOutOfRangeHigh
+- testFollowerFetchOutOfRangeLow
+- testLeaderEpochChangeDuringFencedFetchEpochsFromLeader
+- testLeaderEpochChangeDuringSuccessfulFetchEpochsFromLeader
+- testMaybeUpdateTopicIds
+- testMetricsRemovedOnShutdown
+- testPartitionsInError
+- testRetryAfterUnknownLeaderEpochInLatestOffsetFetch
- testSimpleFetch
+- testTruncateToEpochEndOffsetsDuringRemovePartitions
+- testTruncateToHighWatermarkDuringRemovePartitions
- testTruncateToHighWatermarkIfLeaderEpochInfoNotAvailable
+- testTruncateToHighWatermarkIfLeaderEpochRequestNotSupported
+- testTruncation
+- testTruncationSkippedIfNoEpochChange
+-
testTruncationThrowsExceptionIfLeaderReturnsPartitionsNotRequestedInFetchEpochs
+- testUnknownLeaderEpochInTruncation
+- testUnknownLeaderEpochWhileFetching
kafka.server.AddPartitionsToTxnManagerTest:
- testAddPartitionsToTxnHandlerErrorHandling
- testAddPartitionsToTxnManagerMetrics
@@ -2269,6 +2333,7 @@ kafka.server.AlterUserScramCredentialsRequestTest:
- testDeleteSomethingThatDoesNotExist
- testMetadataVersionTooLow
kafka.server.ApiVersionManagerTest:
+- testApiScope
- testControllerApiIntersection
- testDisabledApis
- testEnvelopeDisabledForKRaftBroker
diff --git a/test-catalog/metadata/tests.yaml b/test-catalog/metadata/tests.yaml
index 290f2d13b47..e08c40818da 100644
--- a/test-catalog/metadata/tests.yaml
+++ b/test-catalog/metadata/tests.yaml
@@ -84,9 +84,22 @@ org.apache.kafka.controller.ConfigurationControlManagerTest:
- testLegacyAlterConfigs
- testReplay
org.apache.kafka.controller.FeatureControlManagerTest:
+- testApplyMetadataVersionChangeRecord
+- testCanUpgradeToHigherVersion
+- testCanUseSafeDowngradeIfMetadataDidNotChange
+- testCannotDowngradeBefore3_3_IV0
+- testCannotDowngradeToHigherVersion
+- testCannotDowngradeToVersionBeforeMinimumSupportedKraftVersion
+- testCannotUnsafeDowngradeToHigherVersion
+- testCannotUpgradeToLowerVersion
+- testCannotUseSafeDowngradeIfMetadataChanged
+- testCreateFeatureLevelRecords
- testNoMetadataVersionChangeDuringMigration
+- testReplay
- testReplayRecords
+- testUnsafeDowngradeIsTemporarilyDisabled
- testUpdateFeatures
+- testUpdateFeaturesErrorCases
org.apache.kafka.controller.LogReplayTrackerTest:
- testEmpty
org.apache.kafka.controller.OffsetControlManagerTest:
diff --git a/test-catalog/streams/integration-tests/tests.yaml
b/test-catalog/streams/integration-tests/tests.yaml
index 5627619ddde..cba7e48ca06 100644
--- a/test-catalog/streams/integration-tests/tests.yaml
+++ b/test-catalog/streams/integration-tests/tests.yaml
@@ -158,12 +158,15 @@
org.apache.kafka.streams.integration.MetricsReporterIntegrationTest:
- shouldBeAbleToProvideInitialMetricValueToMetricsReporter
org.apache.kafka.streams.integration.NamedTopologyIntegrationTest:
- shouldAddNamedTopologyToRunningApplicationWithEmptyInitialTopology
+- shouldAddNamedTopologyToRunningApplicationWithMultipleNodes
- shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopology
-
shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopologyWithRepartitioning
- shouldAllowMixedCollectionAndPatternSubscriptionWithMultipleNamedTopologies
- shouldAllowPatternSubscriptionWithMultipleNamedTopologies
-
shouldAllowRemovingAndAddingNamedTopologyToRunningApplicationWithMultipleNodesAndResetsOffsets
- shouldPrefixAllInternalTopicNamesWithNamedTopology
+-
shouldProcessMultipleIdenticalNamedTopologiesWithInMemoryAndPersistentStateStores
+- shouldProcessSingleNamedTopologyAndPrefixInternalTopics
- shouldRemoveAndReplaceTopologicallyIncompatibleNamedTopology
org.apache.kafka.streams.integration.OptimizedKTableIntegrationTest:
- shouldApplyUpdatesToStandbyStore
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index b59c86086b7..96980d60d60 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -1267,6 +1267,13 @@
org.apache.kafka.streams.kstream.internals.KTableMapValuesTest:
- testQueryableValueGetter
org.apache.kafka.streams.kstream.internals.KTableReduceTest:
- shouldAddAndSubtract
+org.apache.kafka.streams.kstream.internals.KTableSourceTest:
+- kTableShouldLogAndMeterOnSkippedRecords
+- kTableShouldLogOnOutOfOrder
+- testKTable
+- testNotSendingOldValue
+- testSendingOldValue
+- testValueGetter
org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest:
- shouldCalculateCorrectOldValuesIfMaterializedEvenIfStateful
- shouldCalculateCorrectOldValuesIfNotStatefulEvenIfNotMaterialized
@@ -2578,12 +2585,80 @@
org.apache.kafka.streams.processor.internals.StreamTaskTest:
-
shouldWrapKafkaExceptionsWithStreamsExceptionAndAddContextWhenPunctuatingWallClockTimeTime
- testMetrics
org.apache.kafka.streams.processor.internals.StreamThreadTest:
+- shouldAlsoPurgeWhenNothingGetsCommitted
+- shouldAlwaysUpdateTasksMetadataAfterChangingState
+- shouldCatchHandleCorruptionOnTaskCorruptedExceptionPath
+- shouldCatchTaskMigratedExceptionOnOnTaskCorruptedExceptionPath
+- shouldCatchTimeoutExceptionFromHandleCorruptionAndInvokeExceptionHandler
+- shouldChangeStateAtStartClose
+- shouldChangeStateInRebalanceListener
+- shouldCheckStateUpdater
+- shouldCheckStateUpdaterInBetweenProcessCalls
+- shouldCommitAfterCommitInterval
+- shouldConstructAdminMetrics
+- shouldCreateMetricsAtStartup
+- shouldCreateStandbyTask
+- shouldEnforceRebalanceWhenScheduledAndNotCurrentlyRebalancing
+- shouldEnforceRebalanceWhenTaskCorruptedExceptionIsThrownForAnActiveTask
+- shouldGetMainAndRestoreConsumerInstanceId
+- shouldGetMainAndRestoreConsumerInstanceIdWithInternalTimeout
- shouldInjectProducerPerThreadUsingClientSupplierOnCreateIfEosV2Enabled
+- shouldInjectSharedProducerForAllTasksUsingClientSupplierOnCreateIfEosDisabled
+- shouldLogAndRecordSkippedMetricForDeserializationException
+- shouldLogAndRecordSkippedRecordsForInvalidTimestamps
+- shouldNotBlockWhenPollingInPartitionsAssignedStateWithoutStateUpdater
+- shouldNotCauseExceptionIfNothingCommitted
+-
shouldNotCloseTaskAndRemoveFromTaskManagerIfInvalidPidMappingOccurredInCommitTransactionWhenSuspendingTasks
+-
shouldNotCloseTaskAndRemoveFromTaskManagerIfPidMappingIsInvalidInCommitTransactionWhenCommitting
+-
shouldNotCloseTaskAndRemoveFromTaskManagerIfProducerGotFencedInCommitTransactionWhenCommitting
+-
shouldNotCloseTaskAndRemoveFromTaskManagerIfProducerGotFencedInCommitTransactionWhenSuspendingTasks
+- shouldNotCloseTaskAndRemoveFromTaskManagerIfProducerWasFencedWhileProcessing
+- shouldNotCloseTaskProducerWhenSuspending
+- shouldNotCommitBeforeTheCommitInterval
- shouldNotCommitNonRunningNonRestoringTasks
+- shouldNotCreateStandbyTaskIfStateStoresHaveLoggingDisabled
+- shouldNotCreateStandbyTaskWithoutStateStores
+- shouldNotEnforceRebalanceWhenCurrentlyRebalancing
+- shouldNotEnforceRebalanceWhenTaskCorruptedExceptionIsThrownForAnInactiveTask
+- shouldNotProcessWhenPartitionRevoked
- shouldNotPurgeBeforeThePurgeInterval
+- shouldNotRecordFailedStreamThread
+- shouldNotReturnDataAfterTaskMigrated
+- shouldNotThrowWhenStandbyTasksAssignedAndNoStateStoresForTopology
+- shouldNotUpdateStandbyTaskWhenPaused
+- shouldOnlyCompleteShutdownAfterRebalanceNotInProgress
+- shouldOnlyShutdownOnce
+- shouldProcessWhenPartitionAssigned
+- shouldProcessWhenRunning
+- shouldProcessWhenStarting
+- shouldPunctuateActiveTask
- shouldPunctuateWithTimestampPreservedInProcessorContext
+- shouldPurgeAfterPurgeInterval
+- shouldRecordCommitLatency
+- shouldRecordFailedStreamThread
+- shouldRecoverFromInvalidOffsetExceptionOnRestoreAndFinishRestore
+- shouldReinitializeRevivedTasksInAnyState
+- shouldRespectNumIterationsInMainLoopWithoutProcessingThreads
+- shouldRespectPollTimeInPartitionsAssignedStateWithStateUpdater
+- shouldResumePollingForPartitionsWithAvailableSpaceBeforePolling
+- shouldReturnActiveTaskMetadataWhileRunningState
+- shouldReturnErrorIfMainConsumerInstanceIdNotInitialized
+- shouldReturnErrorIfProducerInstanceIdNotInitialized
+- shouldReturnErrorIfRestoreConsumerInstanceIdNotInitialized
+- shouldReturnNullIfMainConsumerTelemetryDisabled
+- shouldReturnNullIfProducerTelemetryDisabled
+- shouldReturnNullIfRestoreConsumerTelemetryDisabled
- shouldReturnStandbyTaskMetadataWhileRunningState
+- shouldShutdownTaskManagerOnClose
+- shouldShutdownTaskManagerOnCloseWithoutStart
+- shouldThrowTaskMigratedExceptionHandlingRevocation
+- shouldThrowTaskMigratedExceptionHandlingTaskLost
+- shouldTimeOutOnMainConsumerInstanceId
+- shouldTimeOutOnProducerInstanceId
+- shouldTimeOutOnRestoreConsumerInstanceId
+- shouldTransmitTaskManagerMetrics
- shouldUpdateLagsAfterPolling
+- shouldUpdateStandbyTask
org.apache.kafka.streams.processor.internals.StreamThreadTotalBlockedTimeTest:
- shouldComputeTotalBlockedTime
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest:
