[
https://issues.apache.org/jira/browse/BAHIR-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416966#comment-15416966
]
Sebastian Woehrl commented on BAHIR-51:
---------------------------------------
QoS can also be set when subscribing to a topic. By default it is 1. When the
QoS from the sender and the receiver differ, the lower one is used for
delivery. Depending on the use case and your availability requirements you need
to be able to set the QoS for subscriptions.
> 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)
