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 43746057f52 Update test catalog data for GHA workflow run 14637222214
43746057f52 is described below
commit 43746057f52fb1f235b339855892d086750e8acc
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Apr 24 11:00:13 2025 +0000
Update test catalog data for GHA workflow run 14637222214
Commit:
https://github.com/apache/kafka/commit/3fae785ea0b4f6b5501b3c222c8c55fe25f516d9
GitHub Run: https://github.com/apache/kafka/actions/runs/14637222214
---
test-catalog/clients/tests.yaml | 11 +++++++++++
test-catalog/streams/tests.yaml | 14 ++++++++++++++
2 files changed, 25 insertions(+)
diff --git a/test-catalog/clients/tests.yaml b/test-catalog/clients/tests.yaml
index 64003b82108..df59c6d7946 100644
--- a/test-catalog/clients/tests.yaml
+++ b/test-catalog/clients/tests.yaml
@@ -1103,6 +1103,7 @@
org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumerTest:
- testCommitSyncAwaitsCommitAsyncCompletionWithNonEmptyOffsets
- testCommitted
- testCommittedExceptionThrown
+- testEmptyStreamRebalanceData
- testEndOffsetsTimeoutException
- testEnsureCallbackExecutedByApplicationThread
- testEnsureCommitSyncExecutedCommitAsyncCallbacks
@@ -1148,6 +1149,7 @@
org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumerTest:
- testSeekToBeginningWithException
- testSeekToEnd
- testSeekToEndWithException
+- testStreamRebalanceData
- testSubscribeGeneratesEvent
- testSubscribePatternAgainstBrokerNotSupportingRegex
- testSubscribePatternGeneratesEvent
@@ -2073,6 +2075,7 @@
org.apache.kafka.clients.consumer.internals.RequestFutureTest:
- testVoidFuture
org.apache.kafka.clients.consumer.internals.RequestManagersTest:
- testMemberStateListenerRegistered
+- testStreamMemberStateListenerRegistered
org.apache.kafka.clients.consumer.internals.RequestStateTest:
- testRequestStateSimple
- testTrackInflightOnFailedAttempt
@@ -2313,6 +2316,8 @@
org.apache.kafka.clients.consumer.internals.StreamsGroupHeartbeatRequestManagerT
- testPollOnCloseWhenIsLeaving
- testPollOnCloseWhenIsNotLeaving
- testPropagateCoordinatorFatalErrorToApplicationThread
+- testResetPollTimer
+- testResetPollTimerWhenExpired
- testResettingHeartbeatState
- testSendingHeartbeatIfHeartbeatCanBeSent
- testSendingHeartbeatIfMemberIsJoiningOrAcknowledging
@@ -2537,6 +2542,12 @@
org.apache.kafka.clients.consumer.internals.events.ApplicationEventProcessorTest
- testResetOffsetEvent
- testSeekUnvalidatedEvent
- testSeekUnvalidatedEventWithException
+- testStreamsOnAllTasksLostCallbackCompletedEvent
+-
testStreamsOnAllTasksLostCallbackCompletedEventWithoutStreamsMembershipManager
+- testStreamsOnTasksAssignedCallbackCompletedEvent
+-
testStreamsOnTasksAssignedCallbackCompletedEventWithoutStreamsMembershipManager
+- testStreamsOnTasksRevokedCallbackCompletedEvent
+-
testStreamsOnTasksRevokedCallbackCompletedEventWithoutStreamsMembershipManager
- testSyncCommitEvent
- testSyncCommitEventWithEmptyOffsets
- testSyncCommitEventWithException
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 93ac313588d..1c179793120 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -1789,6 +1789,13 @@
org.apache.kafka.streams.processor.internals.DefaultStateUpdaterTest:
- shouldUpdateSingleStandbyTask
- shouldUpdateStandbyTaskAfterAllActiveStatefulTasksFailed
- shouldUpdateStandbyTaskAfterAllActiveStatefulTasksRemoved
+org.apache.kafka.streams.processor.internals.DefaultStreamsRebalanceListenerTest:
+- testOnAllTasksLost
+- testOnAllTasksLostWithException
+- testOnTasksAssigned
+- testOnTasksAssignedWithException
+- testOnTasksRevoked
+- testOnTasksRevokedWithException
org.apache.kafka.streams.processor.internals.ForwardingDisabledProcessorContextTest:
- shouldThrowOnForward
- shouldThrowOnForwardWithTo
@@ -2722,6 +2729,13 @@
org.apache.kafka.streams.processor.internals.StreamThreadTest:
- shouldTransmitTaskManagerMetrics
- shouldUpdateLagsAfterPolling
- shouldUpdateStandbyTask
+- testGetTopicPartitionInfo
+- testNamedTopologyWithStreamsProtocol
+- testStreamsProtocolRunOnceWithProcessingThreads
+- testStreamsProtocolRunOnceWithoutProcessingThreads
+- testStreamsRebalanceDataWithClassicProtocol
+- testStreamsRebalanceDataWithExtraCopartition
+- testStreamsRebalanceDataWithStreamsProtocol
org.apache.kafka.streams.processor.internals.StreamThreadTotalBlockedTimeTest:
- shouldComputeTotalBlockedTime
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest:
