[ https://issues.apache.org/jira/browse/SPARK-15900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
lichenglin updated SPARK-15900: ------------------------------- Summary: please add a map param on MQTTUtils.createStreamfor setting MqttConnectOptions (was: please add a map param on MQTTUtils.create for setting MqttConnectOptions ) > please add a map param on MQTTUtils.createStreamfor setting > MqttConnectOptions > ------------------------------------------------------------------------------- > > Key: SPARK-15900 > URL: https://issues.apache.org/jira/browse/SPARK-15900 > Project: Spark > Issue Type: New Feature > Components: Streaming > Affects Versions: 1.6.1 > Reporter: lichenglin > > I notice that MQTTReceiver will create a connection with the method > (org.eclipse.paho.client.mqttv3.MqttClient) client.connect() > It just means client.connect(new MqttConnectOptions()); > this causes that we have to use the default MqttConnectOptions and can't set > other param like usename and password. > please add a new method at MQTTUtils.createStream like > createStream(jssc.ssc, brokerUrl, topic, map,storageLevel) > in order to make a none-default MqttConnectOptions. > thanks -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org