Skip to content

Commit 03bc4e2

Browse files
garyrussellartembilan
authored andcommitted
GH-2109: Increase EKB Zookeeper Timeouts
Resolves #2109 Increase default session timeout to 18 seconds to align with Kafka itself. Also make connection timeout the same, similar to Kafka's default behavior. **cherry-pick to 2.8.x, 2.7.x**
1 parent 4753512 commit 03bc4e2

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -115,9 +115,9 @@ public class EmbeddedKafkaBroker implements InitializingBean, DisposableBean {
115115

116116
private static final Duration DEFAULT_ADMIN_TIMEOUT = Duration.ofSeconds(10);
117117

118-
public static final int DEFAULT_ZK_CONNECTION_TIMEOUT = 6000;
118+
public static final int DEFAULT_ZK_SESSION_TIMEOUT = 18000;
119119

120-
public static final int DEFAULT_ZK_SESSION_TIMEOUT = 6000;
120+
public static final int DEFAULT_ZK_CONNECTION_TIMEOUT = DEFAULT_ZK_SESSION_TIMEOUT;
121121

122122
private static final Method GET_BROKER_STATE_METHOD;
123123

0 commit comments

Comments
 (0)