(kafka) branch trunk updated: KAFKA-17524: Add timeout to StreamThreadTest (#17180)

[davidarthur]

This is an automated email from the ASF dual-hosted git repository.

davidarthur pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new b436499557e KAFKA-17524: Add timeout to StreamThreadTest (#17180)
b436499557e is described below

commit b436499557e4d9de89a01818117d6c29d8190a49
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Thu Sep 12 12:17:25 2024 -0700

    KAFKA-17524: Add timeout to StreamThreadTest (#17180)
    
    Adds a 30s default timeout to StreamThreadTest tests.
    
    Reviewers: David Arthur <mum...@gmail.com>
---
 .../org/apache/kafka/streams/processor/internals/StreamThreadTest.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
index f2060cee437..8df29d1b1f7 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
@@ -95,6 +95,7 @@ import org.apache.kafka.test.TestUtils;
 
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.Arguments;
@@ -172,6 +173,7 @@ import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
+@Timeout(300)
 @ExtendWith(MockitoExtension.class)
 @MockitoSettings(strictness = Strictness.STRICT_STUBS)
 public class StreamThreadTest {