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;