[
https://issues.apache.org/jira/browse/BAHIR-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416990#comment-15416990
]
ASF GitHub Bot commented on BAHIR-51:
-------------------------------------
GitHub user ScrapCodes opened a pull request:
https://github.com/apache/bahir/pull/22
[BAHIR-51] MqttStreamSource supports a few important MqttConnectOptions.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ScrapCodes/bahir BAHIR-51
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/bahir/pull/22.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #22
----
commit de08f208454f9a96381d5fac90afb4d33b6ef352
Author: Prashant Sharma <prash...@in.ibm.com>
Date: 2016-08-11T10:26:20Z
[BAHIR-51] MqttStreamSource supports a few important MqttConnectOptions.
----
> 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)
