From 2ef9139d659db4a35ceedac6e9063c5dbe95e080 Mon Sep 17 00:00:00 2001 From: Ryan Jobse Date: Wed, 25 Sep 2024 22:12:52 +0000 Subject: [PATCH] fixing build issues --- .../test/java/org/apache/kafka/clients/NetworkClientTest.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java b/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java index 2dd325707f07..8485d699bd01 100644 --- a/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java @@ -68,6 +68,7 @@ import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertNull; import static org.junit.Assert.assertTrue; +import static org.junit.jupiter.api.Assertions.assertThrows; public class NetworkClientTest { @@ -77,6 +78,8 @@ public class NetworkClientTest { protected final Node node = TestUtils.singletonCluster().nodes().iterator().next(); protected final long reconnectBackoffMsTest = 10 * 1000; protected final long reconnectBackoffMaxMsTest = 10 * 10000; + protected final long connectionSetupTimeoutMsTest = 5 * 1000; + protected final long connectionSetupTimeoutMaxMsTest = 127 * 1000; private final TestMetadataUpdater metadataUpdater = new TestMetadataUpdater(Collections.singletonList(node)); private final TestClusterMetadataUpdater clusterMetadataUpdater = new TestClusterMetadataUpdater(Collections.singletonList(node));