如何使用MQTT Spark流库通过授权连接到MQTT broker

Question

我正在尝试连接具有授权的broker（BlueMix IoT Foundation），但不知道如何提供凭据？如何使用Spark？

Answer 1

无法使用SparkStreaming中的默认MQTT连接器连接到具有授权的代理。您必须以自己的方式重新定义MQTTInputDstream才能启用身份验证。

Answer 2

我已经从Apache spark定制了spark流式mqtt连接器库，并添加了以下内容

• 添加了TLS v1.2安全性，使通信始终处于安全状态
• 存储的主题以及RDD中的有效负载

图书馆在这里提供-https://github.com/sathipal/spark-streaming-mqtt-with-security_2.10-1.3.0.此外，还增加了如何使用该库连接到IBM Watson物联网平台的更多细节。如果您有任何疑问，请告诉我。