Sebastian Woehrl created BAHIR-51:
-------------------------------------
Summary: 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)
