lichenglin created SPARK-15900: ---------------------------------- Summary: please add a map param on MQTTUtils.create for 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