Does cruise-control support securityProtocol SASL_PLAINTEXT about cruise-control HOT 10 CLOSED

	security.protocol = SASL_PLAINTEXT
 (com.linkedin.kafka.cruisecontrol.config.KafkaCruiseControlConfig)
Exception in thread "main" java.lang.IllegalArgumentException: `clientSaslMechanism` must be non-null in client mode if `securityProtocol` is `SASL_PLAINTEXT`
	at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:59)
	at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:85)
	at com.linkedin.kafka.cruisecontrol.common.MetadataClient.<init>(MetadataClient.java:43)
	at com.linkedin.kafka.cruisecontrol.monitor.LoadMonitor.<init>(LoadMonitor.java:94)
	at com.linkedin.kafka.cruisecontrol.KafkaCruiseControl.<init>(KafkaCruiseControl.java:75)
	at com.linkedin.kafka.cruisecontrol.KafkaCruiseControlMain.main(KafkaCruiseControlMain.java:47)

$ egrep "sasl.mechanism|security.protocol" config/cruisecontrol.properties 
security.protocol=SASL_PLAINTEXT
sasl.mechanism=GSSAPI

[2017-10-18 14:30:42,634] INFO Client will use GSSAPI as SASL mechanism. (org.apache.zookeeper.client.ZooKeeperSaslClient)
[2017-10-18 14:30:42,635] INFO Opening socket connection to server ns-hd06/172.25.26.6:2181. Will attempt to SASL-authenticate using Login Context section 'Client' (org.apache.zookeeper.ClientCnxn)
[2017-10-18 14:30:42,636] INFO Socket connection established to ns-hd06/172.25.26.6:2181, initiating session (org.apache.zookeeper.ClientCnxn)
[2017-10-18 14:30:42,685] INFO Session establishment complete on server ns-hd06/172.25.26.6:2181, sessionid = 0x15f2e4a04030007, negotiated timeout = 30000 (org.apache.zookeeper.ClientCnxn)
[2017-10-18 14:30:42,687] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
[2017-10-18 14:30:42,838] INFO zookeeper state changed (SaslAuthenticated) (org.I0Itec.zkclient.ZkClient)
Exception in thread "main" kafka.common.KafkaException: Failed to parse the broker info from zookeeper: {"jmx_port":-1,"timestamp":"1508310423499","endpoints":["PLAINTEXTSASL://ns-hd07:6667"],"host":null,"version":3,"port":-1}
	at kafka.cluster.Broker$.createBroker(Broker.scala:125)
	at kafka.utils.ZkUtils.getBrokerInfo(ZkUtils.scala:843)
	at kafka.utils.ZkUtils$$anonfun$getAllBrokersInCluster$2.apply(ZkUtils.scala:286)
	at kafka.utils.ZkUtils$$anonfun$getAllBrokersInCluster$2.apply(ZkUtils.scala:286)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
	at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
	at scala.collection.AbstractTraversable.map(Traversable.scala:104)
	at kafka.utils.ZkUtils.getAllBrokersInCluster(ZkUtils.scala:286)
	at com.linkedin.kafka.cruisecontrol.monitor.sampling.KafkaSampleStore.ensureTopicCreated(KafkaSampleStore.java:131)
	at com.linkedin.kafka.cruisecontrol.monitor.sampling.KafkaSampleStore.configure(KafkaSampleStore.java:104)
	at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:207)
	at com.linkedin.kafka.cruisecontrol.monitor.task.LoadMonitorTaskRunner.<init>(LoadMonitorTaskRunner.java:86)
	at com.linkedin.kafka.cruisecontrol.monitor.task.LoadMonitorTaskRunner.<init>(LoadMonitorTaskRunner.java:61)
	at com.linkedin.kafka.cruisecontrol.monitor.LoadMonitor.<init>(LoadMonitor.java:130)
	at com.linkedin.kafka.cruisecontrol.monitor.LoadMonitor.<init>(LoadMonitor.java:93)
	at com.linkedin.kafka.cruisecontrol.KafkaCruiseControl.<init>(KafkaCruiseControl.java:75)
	at com.linkedin.kafka.cruisecontrol.KafkaCruiseControlMain.main(KafkaCruiseControlMain.java:47)
Caused by: java.lang.IllegalArgumentException: No security protocol defined for listener PLAINTEXTSASL
	at kafka.cluster.EndPoint$$anonfun$securityProtocol$1$1.apply(EndPoint.scala:48)
	at kafka.cluster.EndPoint$$anonfun$securityProtocol$1$1.apply(EndPoint.scala:48)
	at scala.collection.MapLike$class.getOrElse(MapLike.scala:128)
	at scala.collection.AbstractMap.getOrElse(Map.scala:59)
	at kafka.cluster.EndPoint$.securityProtocol$1(EndPoint.scala:47)
	at kafka.cluster.EndPoint$.createEndPoint(EndPoint.scala:56)
	at kafka.cluster.Broker$$anonfun$2.apply(Broker.scala:115)
	at kafka.cluster.Broker$$anonfun$2.apply(Broker.scala:115)
	at scala.collection.immutable.List.map(List.scala:284)
	at kafka.cluster.Broker$.createBroker(Broker.scala:115)
	... 19 more