(kafka) branch trunk updated: KAFKA-20830 Speed up testFailToStartWhenInternalTopicsAreNotCompacted (#22931)

[chia7712]

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

chia7712 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 a9fa6f7c715 KAFKA-20830 Speed up 
testFailToStartWhenInternalTopicsAreNotCompacted (#22931)
a9fa6f7c715 is described below

commit a9fa6f7c715c46712d208df8faa976b6a12d3f34
Author: red-flames <hjtiun...@gmail.com>
AuthorDate: Sun Jul 26 13:12:15 2026 +0800

    KAFKA-20830 Speed up testFailToStartWhenInternalTopicsAreNotCompacted 
(#22931)
    
    The test uses REST to verify the health of a dead worker, but the
    default timeout is 10 seconds. That means it takes 30 seconds (3 * 10
    seconds) to complete all verifications for a run. So we add
    connect.requestTimeout(1000) to speed it up. The timeout has to be set
    after every addWorker() call since a new worker starts with the default
    timeout.
    
    Locally this cuts the test time from 1m41.50s to 20.802s (times taken
    from the JUnit report). The ~81s difference matches the expected saving:
    9 health checks (3 rounds x 3 assertions) x 9s shorter timeout.
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 .../kafka/connect/integration/InternalTopicsIntegrationTest.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/InternalTopicsIntegrationTest.java
 
b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/InternalTopicsIntegrationTest.java
index d0841b26941..50871fa7257 100644
--- 
a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/InternalTopicsIntegrationTest.java
+++ 
b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/InternalTopicsIntegrationTest.java
@@ -212,6 +212,9 @@ public class InternalTopicsIntegrationTest {
 
         // Try to start one worker, with three bad topics
         WorkerHandle worker = connect.addWorker(); // should have failed to 
start before returning
+        // The worker is expected to fail startup, so shorten the request 
timeout to avoid
+        // blocking for the default 10 seconds on every health check.
+        connect.requestTimeout(1000);
         assertFalse(connect.isHealthy(worker));
         assertFalse(connect.allWorkersHealthy());
         assertFalse(connect.anyWorkersHealthy());
@@ -222,6 +225,7 @@ public class InternalTopicsIntegrationTest {
 
         // Try to start one worker, with two bad topics remaining
         worker = connect.addWorker(); // should have failed to start before 
returning
+        connect.requestTimeout(1000);
         assertFalse(connect.isHealthy(worker));
         assertFalse(connect.allWorkersHealthy());
         assertFalse(connect.anyWorkersHealthy());
@@ -232,6 +236,7 @@ public class InternalTopicsIntegrationTest {
 
         // Try to start one worker, with one bad topic remaining
         worker = connect.addWorker(); // should have failed to start before 
returning
+        connect.requestTimeout(1000);
         assertFalse(connect.isHealthy(worker));
         assertFalse(connect.allWorkersHealthy());
         assertFalse(connect.anyWorkersHealthy());