[jira] [Commented] (BAHIR-51) Add additional MQTT options/parameters to MQTTInputDStream and MqttStreamSource

["Prashant Sharma (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/BAHIR-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416952#comment-15416952 ] 

Prashant Sharma commented on BAHIR-51:
--------------------------------------

QoS is set on message, when it is published. There is no way, I could see to set QoS on the receiver.

> Add additional MQTT options/parameters to MQTTInputDStream and MqttStreamSource
> -------------------------------------------------------------------------------
>
>                 Key: BAHIR-51
>                 URL: https://issues.apache.org/jira/browse/BAHIR-51
>             Project: Bahir
>          Issue Type: Improvement
>          Components: Spark Streaming Connectors, Spark Structured Streaming Connectors
>            Reporter: Sebastian Woehrl
>
> We are using Spark Streaming in the automotive IOT environment with MQTT as the data source.
> For security reasons our MQTT broker is protected by username and password (as is default for these kind of environments). At the moment it is not possible to set username/password when creating an MQTT Receiver (MQTTInputDStream or MqttStreamSource).
> I propose that the MQTTInputDStream and MqttStreamSource be extended to optionally allow setting the following mqtt options / parameters:
> * username
> * password
> * clientId
> * cleanSession
> * QoS
> * connectionTimeout
> * keepAliveInterval
> * mqttVersion
> If this proposal meets your approval I am willing to create a pull request with these changes implemented.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)