This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.0 by this push:
new cc04583 MINOR: kraft quorum configs should not be internal #11030
cc04583 is described below
commit cc04583dba2e0588b0d961043406aa16283423e7
Author: Ryan Dielhenn <[email protected]>
AuthorDate: Mon Jul 12 14:20:58 2021 -0700
MINOR: kraft quorum configs should not be internal #11030
Reviewers: David Arthur <[email protected]>
---
core/src/main/scala/kafka/server/KafkaConfig.scala | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala
b/core/src/main/scala/kafka/server/KafkaConfig.scala
index 6a3c97b..cada670 100755
--- a/core/src/main/scala/kafka/server/KafkaConfig.scala
+++ b/core/src/main/scala/kafka/server/KafkaConfig.scala
@@ -1292,13 +1292,13 @@ object KafkaConfig {
.define(PasswordEncoderIterationsProp, INT,
Defaults.PasswordEncoderIterations, atLeast(1024), LOW,
PasswordEncoderIterationsDoc)
/** ********* Raft Quorum Configuration *********/
- .defineInternal(RaftConfig.QUORUM_VOTERS_CONFIG, LIST,
Defaults.QuorumVoters, new RaftConfig.ControllerQuorumVotersValidator(), HIGH,
RaftConfig.QUORUM_VOTERS_DOC)
- .defineInternal(RaftConfig.QUORUM_ELECTION_TIMEOUT_MS_CONFIG, INT,
Defaults.QuorumElectionTimeoutMs, null, HIGH,
RaftConfig.QUORUM_ELECTION_TIMEOUT_MS_DOC)
- .defineInternal(RaftConfig.QUORUM_FETCH_TIMEOUT_MS_CONFIG, INT,
Defaults.QuorumFetchTimeoutMs, null, HIGH,
RaftConfig.QUORUM_FETCH_TIMEOUT_MS_DOC)
- .defineInternal(RaftConfig.QUORUM_ELECTION_BACKOFF_MAX_MS_CONFIG, INT,
Defaults.QuorumElectionBackoffMs, null, HIGH,
RaftConfig.QUORUM_ELECTION_BACKOFF_MAX_MS_DOC)
- .defineInternal(RaftConfig.QUORUM_LINGER_MS_CONFIG, INT,
Defaults.QuorumLingerMs, null, MEDIUM, RaftConfig.QUORUM_LINGER_MS_DOC)
- .defineInternal(RaftConfig.QUORUM_REQUEST_TIMEOUT_MS_CONFIG, INT,
Defaults.QuorumRequestTimeoutMs, null, MEDIUM,
RaftConfig.QUORUM_REQUEST_TIMEOUT_MS_DOC)
- .defineInternal(RaftConfig.QUORUM_RETRY_BACKOFF_MS_CONFIG, INT,
Defaults.QuorumRetryBackoffMs, null, LOW,
RaftConfig.QUORUM_RETRY_BACKOFF_MS_DOC)
+ .define(RaftConfig.QUORUM_VOTERS_CONFIG, LIST, Defaults.QuorumVoters,
new RaftConfig.ControllerQuorumVotersValidator(), HIGH,
RaftConfig.QUORUM_VOTERS_DOC)
+ .define(RaftConfig.QUORUM_ELECTION_TIMEOUT_MS_CONFIG, INT,
Defaults.QuorumElectionTimeoutMs, null, HIGH,
RaftConfig.QUORUM_ELECTION_TIMEOUT_MS_DOC)
+ .define(RaftConfig.QUORUM_FETCH_TIMEOUT_MS_CONFIG, INT,
Defaults.QuorumFetchTimeoutMs, null, HIGH,
RaftConfig.QUORUM_FETCH_TIMEOUT_MS_DOC)
+ .define(RaftConfig.QUORUM_ELECTION_BACKOFF_MAX_MS_CONFIG, INT,
Defaults.QuorumElectionBackoffMs, null, HIGH,
RaftConfig.QUORUM_ELECTION_BACKOFF_MAX_MS_DOC)
+ .define(RaftConfig.QUORUM_LINGER_MS_CONFIG, INT,
Defaults.QuorumLingerMs, null, MEDIUM, RaftConfig.QUORUM_LINGER_MS_DOC)
+ .define(RaftConfig.QUORUM_REQUEST_TIMEOUT_MS_CONFIG, INT,
Defaults.QuorumRequestTimeoutMs, null, MEDIUM,
RaftConfig.QUORUM_REQUEST_TIMEOUT_MS_DOC)
+ .define(RaftConfig.QUORUM_RETRY_BACKOFF_MS_CONFIG, INT,
Defaults.QuorumRetryBackoffMs, null, LOW,
RaftConfig.QUORUM_RETRY_BACKOFF_MS_DOC)
}
/** ********* Remote Log Management Configuration *********/