In the Hortonworks article about connecting the Kafka spout to a secure Kafka cluster it says that you need to set 'spoutConfig.securityProtocol=PLAINTEXTSASL' for the Kafka spout config (Configuring KafkaSpout to Connect to a Secure Kafka Cluster). However the securityProtocol property does not exist as part of the config, so this article appears to be out of date. KafkaConfig.java In the Storm issue tracker they make mention of the fact that securityProtocol was never meant to be part of the public release (STORM-822: Kafka Spout New Consumer API #1131).
"securityProtocol is not needed any more, and was actually never in open source" So my question is: How can I correctly configure the Kafka Spout to connect to a secured Kafka cluster?
... View more