This is an automated email from the ASF dual-hosted git repository.

showuon pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 2a656aea27 MINOR: fix typo for QUORUM_FETCH_TIMEOUT_MS_DOC (#12132)
2a656aea27 is described below

commit 2a656aea27c7ed63acb40dae1ce710ddea50f46d
Author: Jacklee <[email protected]>
AuthorDate: Tue May 10 10:47:23 2022 +0800

    MINOR: fix typo for QUORUM_FETCH_TIMEOUT_MS_DOC (#12132)
    
    Reviewers: Luke Chen <[email protected]>
---
 raft/src/main/java/org/apache/kafka/raft/RaftConfig.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/raft/src/main/java/org/apache/kafka/raft/RaftConfig.java 
b/raft/src/main/java/org/apache/kafka/raft/RaftConfig.java
index 0833df0bb2..3ce72a591f 100644
--- a/raft/src/main/java/org/apache/kafka/raft/RaftConfig.java
+++ b/raft/src/main/java/org/apache/kafka/raft/RaftConfig.java
@@ -68,7 +68,7 @@ public class RaftConfig {
 
     public static final String QUORUM_FETCH_TIMEOUT_MS_CONFIG = QUORUM_PREFIX 
+ "fetch.timeout.ms";
     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 a 
election for voters; Maximum time without " +
+        "the current leader before becoming a candidate and triggering an 
election for voters; Maximum time without " +
         "receiving fetch from a majority of the quorum before asking around to 
see if there's a new epoch for leader";
     public static final int DEFAULT_QUORUM_FETCH_TIMEOUT_MS = 2_000;
 

Reply via email to