Hi Darshan, I am not aware of any documentation in the Bahir project regarding this, but the sql-streaming-mqtt connector uses the Eclipse Paho Java Client (v3): https://github.com/apache/bahir/blob/master/sql-streaming-mqtt/src/main/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSource.scala#L99
... which can be configured to use SSL via the MqttConnectOptions: https://github.com/apache/bahir/blob/master/sql-streaming-mqtt/src/main/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSource.scala#L123 ... to use SSLSocketFactory: https://github.com/eclipse/paho.mqtt.java/blob/master/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttConnectOptions.java#L302 ... and set SSL properties: https://github.com/eclipse/paho.mqtt.java/blob/master/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttConnectOptions.java#L409 I hope this helps. Best regards, Christian Kadner From: Darshan Pandya <[email protected]> To: [email protected] Date: 08/29/2017 10:28 AM Subject: SSL support for MQTT Structured Streaming connector Hello, I am using the MQTT Structured Streaming connector from Bahir - was wondering if there is any documentation to use it with SSL ? Please advise. -- Sincerely, Darshan
