chore(config): change quorum default timeout to 5s (#1824)

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Aug 16, 2024 · daea645 · daea645
1 parent 385b5b1
commit daea645
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java b/raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java
@@ -70,7 +70,7 @@ public class QuorumConfig {
     public static final String QUORUM_FETCH_TIMEOUT_MS_DOC = "Maximum time without a successful fetch from " +
         "the current leader before becoming a candidate and triggering an election for voters; Maximum time " +
         "a leader can go without receiving valid fetch or fetchSnapshot request from a majority of the quorum before resigning.";
-    public static final int DEFAULT_QUORUM_FETCH_TIMEOUT_MS = 2_000;
+    public static final int DEFAULT_QUORUM_FETCH_TIMEOUT_MS = 5_000;
 
     public static final String QUORUM_ELECTION_BACKOFF_MAX_MS_CONFIG = QUORUM_PREFIX + "election.backoff.max.ms";
     public static final String QUORUM_ELECTION_BACKOFF_MAX_MS_DOC = "Maximum time in milliseconds before starting new elections. " +
@@ -85,7 +85,7 @@ public class QuorumConfig {
     public static final String QUORUM_REQUEST_TIMEOUT_MS_CONFIG = QUORUM_PREFIX +
         CommonClientConfigs.REQUEST_TIMEOUT_MS_CONFIG;
     public static final String QUORUM_REQUEST_TIMEOUT_MS_DOC = CommonClientConfigs.REQUEST_TIMEOUT_MS_DOC;
-    public static final int DEFAULT_QUORUM_REQUEST_TIMEOUT_MS = 2_000;
+    public static final int DEFAULT_QUORUM_REQUEST_TIMEOUT_MS = 5_000;
 
     public static final String QUORUM_RETRY_BACKOFF_MS_CONFIG = QUORUM_PREFIX +
         CommonClientConfigs.RETRY_BACKOFF_MS_CONFIG;