Skip to content

Commit fefebd1

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 3325e36 commit fefebd1

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
@@ -116,9 +116,9 @@ public class EmbeddedKafkaBroker implements InitializingBean, DisposableBean {
116116

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

119-
public static final int DEFAULT_ZK_CONNECTION_TIMEOUT = 6000;
119+
public static final int DEFAULT_ZK_SESSION_TIMEOUT = 18000;
120120

121-
public static final int DEFAULT_ZK_SESSION_TIMEOUT = 6000;
121+
public static final int DEFAULT_ZK_CONNECTION_TIMEOUT = DEFAULT_ZK_SESSION_TIMEOUT;
122122

123123
private static final Method GET_BROKER_STATE_METHOD;
124124

0 commit comments

Comments
 (0)