如何使用 MQTT Spark 流媒体库授权连接到 MQTT 代理答案

【问题标题】：How to connect to MQTT broker with authorization with MQTT Spark streaming library如何使用 MQTT Spark 流媒体库授权连接到 MQTT 代理
【发布时间】：2015-12-17 10:14:45
【问题描述】：

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

【问题讨论】：

您能说一下您是如何尝试连接的吗？发布您的代码绝不是一个坏主意:)

标签： scala apache-spark ibm-cloud spark-streaming mqtt

【解决方案1】：

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

【讨论】：

【解决方案2】：

我从 Apache Spark 定制了 spark-streaming-mqtt-connector 库并添加了以下内容，

添加了 TLS v1.2 安全性，以便始终确保通信安全。
将主题与负载一起存储在 RDD 中。

该库在此处可用 - https://github.com/sathipal/spark-streaming-mqtt-with-security_2.10-1.3.0。此外，还添加了有关如何使用该库连接到 IBM Watson IoT Platform 的更多详细信息。如果您有任何疑问，请告诉我。

【讨论】：