RivenSun2 commented on code in PR #12010: URL: https://github.com/apache/kafka/pull/12010#discussion_r852494899
########## core/src/main/scala/kafka/server/KafkaConfig.scala: ########## @@ -1324,9 +1324,9 @@ object KafkaConfig { .define(SslEngineFactoryClassProp, CLASS, null, LOW, SslEngineFactoryClassDoc) /** ********* Sasl Configuration ****************/ - .define(SaslMechanismInterBrokerProtocolProp, STRING, Defaults.SaslMechanismInterBrokerProtocol, MEDIUM, SaslMechanismInterBrokerProtocolDoc) + .define(SaslMechanismInterBrokerProtocolProp, STRING, Defaults.SaslMechanismInterBrokerProtocol, ConfigDef.CompositeValidator.of(new ConfigDef.NonNullValidator(), new ConfigDef.NonEmptyString()), MEDIUM, SaslMechanismInterBrokerProtocolDoc) .define(SaslJaasConfigProp, PASSWORD, null, MEDIUM, SaslJaasConfigDoc) - .define(SaslEnabledMechanismsProp, LIST, Defaults.SaslEnabledMechanisms, MEDIUM, SaslEnabledMechanismsDoc) + .define(SaslEnabledMechanismsProp, LIST, Defaults.SaslEnabledMechanisms, new BrokerSecurityConfigs.SaslEnabledMechanismsValidator(), MEDIUM, SaslEnabledMechanismsDoc) Review Comment: > Is it possible today to bring up a MirrorMaker 2 instance with security.protocol set to SASL without it failing? According to the official website https://kafka.apache.org/documentation/#producerconfigs_security.protocol, the valid values of `security.protocol` are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL. Currently this legal values apply to Producer, Consumer, KafkaConnect, KafkaStreams, Adminclient and `security.inter.broker.protocol`. I'm also not sure if there are different legal values for the `security.protocol` parameter in `Mirrormaker`. If it is indeed different, I think we can do a separate treatment for `Mirrormaker`. As far as I know, SASL is just a switch that turns on the authentication mechanism, it is not a specific communication protocol. It needs to be used with the transport layer protocol. For example: SASL_PLAINTEXT or SASL_SSL. WDYT? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org