(kafka) branch trunk updated: MINOR: Fix StreamThreadTest (#20210)

[lucasbru]

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

lucasbru 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 ed22a8b6cb4 MINOR: Fix StreamThreadTest (#20210)
ed22a8b6cb4 is described below

commit ed22a8b6cb4d308af85ab8035ab52bf28835c4c9
Author: Jinhe Zhang <raide...@outlook.com>
AuthorDate: Tue Jul 22 05:04:23 2025 -0400

    MINOR: Fix StreamThreadTest (#20210)
    
    There is a typo in the unit test, it calls
    `runOnceWithoutProcessingThreads` while it should call
    `runOnceWithProcessingThreads` instead.
    
    Reviewers: Lucas Brutschy <lucas...@apache.org>
---
 .../org/apache/kafka/streams/processor/internals/StreamThreadTest.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 603cbe55b0e..2d56ed6f402 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
@@ -4047,7 +4047,7 @@ public class StreamThreadTest {
                         
.setStatusCode(StreamsGroupHeartbeatResponse.Status.MISSING_SOURCE_TOPICS.code())
                         .setStatusDetail("Missing source topics")
         ));
-        final MissingSourceTopicException exception = 
assertThrows(MissingSourceTopicException.class, () -> 
thread.runOnceWithoutProcessingThreads());
+        final MissingSourceTopicException exception = 
assertThrows(MissingSourceTopicException.class, () -> 
thread.runOnceWithProcessingThreads());
         assertTrue(exception.getMessage().startsWith("Missing source topics"));
     }