我想知道是否有Kafka喷口支持安全的Kafka经纪人。apachestorm的kafkaspout不支持ssl-kafka。

public KafkaSpout(SpoutConfig spoutConf) {
    _spoutConfig = spoutConf;
}

下面提到的kafka不接受ssl kafka生产者/消费者支持的任何参数。

public KafkaConfig(BrokerHosts hosts, String topic) {
        this(hosts, topic, kafka.api.OffsetRequest.DefaultClientId());
    }

    public KafkaConfig(BrokerHosts hosts, String topic, String clientId) {
        this.hosts = hosts;
        this.topic = topic;
        this.clientId = clientId;
    }

请让我知道有任何方法，我们可以实现安全的Kafka消息流处理与风暴拓扑。