Skip to content

Commit

Permalink
GH-2109: Increase EKB Zookeeper Timeouts
Browse files Browse the repository at this point in the history
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**
  • Loading branch information
garyrussell authored and artembilan committed Feb 17, 2022
1 parent 4753512 commit 03bc4e2
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -115,9 +115,9 @@ public class EmbeddedKafkaBroker implements InitializingBean, DisposableBean {

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

public static final int DEFAULT_ZK_CONNECTION_TIMEOUT = 6000;
public static final int DEFAULT_ZK_SESSION_TIMEOUT = 18000;

public static final int DEFAULT_ZK_SESSION_TIMEOUT = 6000;
public static final int DEFAULT_ZK_CONNECTION_TIMEOUT = DEFAULT_ZK_SESSION_TIMEOUT;

private static final Method GET_BROKER_STATE_METHOD;

Expand Down

0 comments on commit 03bc4e2

Please sign in to comment.