You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "David Arthur (Jira)" <ji...@apache.org> on 2021/07/07 15:14:00 UTC

[jira] [Commented] (KAFKA-12992) Make kraft configuration properties public

    [ https://issues.apache.org/jira/browse/KAFKA-12992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376635#comment-17376635 ] 

David Arthur commented on KAFKA-12992:
--------------------------------------

Some additional properties were added as part of KAFKA-12155, I also marked them as public for the 3.0 release. https://github.com/apache/kafka/commit/284ec262c6c84063d90271c965e4cbc1eda111fe#diff-cbe6a8b71b05ed22cf09d97591225b588e9fca6caaf95d3b34a43262cfd23aa6

> Make kraft configuration properties public
> ------------------------------------------
>
>                 Key: KAFKA-12992
>                 URL: https://issues.apache.org/jira/browse/KAFKA-12992
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: core
>            Reporter: Jose Armando Garcia Sancio
>            Assignee: HaiyuanZhao
>            Priority: Blocker
>              Labels: kip-500
>             Fix For: 3.0.0
>
>
> All of the Kraft configurations should be made public:
> {code:java}
>         /*
>          * KRaft mode configs. Note that these configs are defined as internal. We will make them public in the 3.0.0 release.
>          */
>         .defineInternal(ProcessRolesProp, LIST, Collections.emptyList(), ValidList.in("broker", "controller"), HIGH, ProcessRolesDoc)
>         .defineInternal(NodeIdProp, INT, Defaults.EmptyNodeId, null, HIGH, NodeIdDoc)
>         .defineInternal(InitialBrokerRegistrationTimeoutMsProp, INT, Defaults.InitialBrokerRegistrationTimeoutMs, null, MEDIUM, InitialBrokerRegistrationTimeoutMsDoc)
>         .defineInternal(BrokerHeartbeatIntervalMsProp, INT, Defaults.BrokerHeartbeatIntervalMs, null, MEDIUM, BrokerHeartbeatIntervalMsDoc)
>         .defineInternal(BrokerSessionTimeoutMsProp, INT, Defaults.BrokerSessionTimeoutMs, null, MEDIUM, BrokerSessionTimeoutMsDoc)
>         .defineInternal(MetadataLogDirProp, STRING, null, null, HIGH, MetadataLogDirDoc)
>         .defineInternal(ControllerListenerNamesProp, STRING, null, null, HIGH, ControllerListenerNamesDoc)
>         .defineInternal(SaslMechanismControllerProtocolProp, STRING, SaslConfigs.DEFAULT_SASL_MECHANISM, null, HIGH, SaslMechanismControllerProtocolDoc)
>  {code}
>  
> https://github.com/apache/kafka/blob/2beaf9a720330615bc5474ec079f8b4b105eff91/core/src/main/scala/kafka/server/KafkaConfig.scala#L1043-L1053



--
This message was sent by Atlassian Jira
(v8.3.4#803005)