Hi Christian, I did dissect this out - was wondering why these options weren't enabled in the sql-streaming-mqtt connector out of the box and if there is a chance to contribute by enabling these options. Looks pretty simple to enable these. At the end of the day I don't want to maintain this code at my end but simply use it as a dependency. Bahir will benefit from this contribution, no ?
Sincerely, Darshan On Wed, Aug 30, 2017 at 4:30 PM, Christian R Kadner <ckad...@us.ibm.com> wrote: > 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 > > [image: Inactive hide details for Darshan Pandya ---08/29/2017 10:28:47 > AM---Hello, I am using the MQTT Structured Streaming connector]Darshan > Pandya ---08/29/2017 10:28:47 AM---Hello, I am using the MQTT Structured > Streaming connector from Bahir - was > > From: Darshan Pandya <darshanpan...@gmail.com> > To: user@bahir.apache.org > 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 > > > > -- Sincerely, Darshan