Skip to content
This repository was archived by the owner on Jan 24, 2024. It is now read-only.

Commit 8d180ad

Browse files
committed
Increase timeout for KafkaListenerNameTest (#1831)
Fixes #1830 ### Motivation Different from other tests, the `KafkaListenerNameTest` sets up and cleans up the broker service during the test method, which will take much more time than other tests. `testConnectListenerNotExist` is more flaky because the timeout is 20 seconds while other methods are 30. ### Modifications Increase all timeout of `KafkaListenerNameTest` to 1 minute. (cherry picked from commit b00a4c5)
1 parent fd67cca commit 8d180ad

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

tests/src/test/java/io/streamnative/pulsar/handlers/kop/KafkaListenerNameTest.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ protected void cleanup() throws Exception {
6464
// Clean up in the test method
6565
}
6666

67-
@Test(timeOut = 30000)
67+
@Test(timeOut = 60000)
6868
public void testMetadataRequestForMultiListeners() throws Exception {
6969
final Map<Integer, InetSocketAddress> bindPortToAdvertisedAddress = new HashMap<>();
7070
final int anotherKafkaPort = PortManager.nextFreePort();
@@ -134,7 +134,7 @@ public void testMetadataRequestForMultiListeners() throws Exception {
134134
super.internalCleanup();
135135
}
136136

137-
@Test(timeOut = 30000)
137+
@Test(timeOut = 60000)
138138
public void testListenerName() throws Exception {
139139
super.resetConfig();
140140
conf.setAdvertisedAddress(null);
@@ -152,7 +152,7 @@ public void testListenerName() throws Exception {
152152
super.internalCleanup();
153153
}
154154

155-
@Test(timeOut = 30000)
155+
@Test(timeOut = 60000)
156156
public void testLegacyMultipleListenerName() throws Exception {
157157
super.resetConfig();
158158
conf.setAdvertisedAddress(null);
@@ -189,7 +189,7 @@ public void testLegacyMultipleListenerName() throws Exception {
189189
super.internalCleanup();
190190
}
191191

192-
@Test(timeOut = 20000)
192+
@Test(timeOut = 60000)
193193
public void testConnectListenerNotExist() throws Exception {
194194
final int externalPort = PortManager.nextFreePort();
195195
super.resetConfig();
@@ -217,7 +217,7 @@ public void testConnectListenerNotExist() throws Exception {
217217
super.internalCleanup();
218218
}
219219

220-
@Test(timeOut = 30000)
220+
@Test(timeOut = 60000)
221221
public void testIpv6ListenerName() throws Exception {
222222
super.resetConfig();
223223
conf.setAdvertisedAddress(null);

0 commit comments

Comments
 (0)