From b436499557e4d9de89a01818117d6c29d8190a49 Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Thu, 12 Sep 2024 12:17:25 -0700 Subject: [PATCH] KAFKA-17524: Add timeout to StreamThreadTest (#17180) Adds a 30s default timeout to StreamThreadTest tests. Reviewers: David Arthur --- .../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 f2060cee437bf..8df29d1b1f767 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.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.verify; import static org.mockito.Mockito.when; +@Timeout(300) @ExtendWith(MockitoExtension.class) @MockitoSettings(strictness = Strictness.STRICT_STUBS) public class StreamThreadTest {