我想将 Spark 订阅到 ActiveMQ 或 Mosquitto MQTT 代理。我怎样才能做到这一点？
问问题
2757 次
3 回答
1
Apache 孵化器 Spark 存储库中用于 Spark 流的 MQTT 适配器的更新请求和代码在这里，请参阅合并提交https://github.com/apache/spark/commit/dd659642e77dca9a123178f98e399720127454c2
于 2013-10-19T03:56:40.437 回答
0
有一个将MQTT 输入源添加到 Spark Streaming 的拉取请求。我们决定现在不接受这个 PR（我们想在支持它之前判断对 MQTT 的需求），但是你应该可以拿那个 PR 的代码并把它放在你自己的包中。
此外，请查看Spark Streaming 自定义接收器指南，了解有关编写自定义输入接收器的信息。
于 2013-10-07T19:57:56.647 回答
0
您可以编写自定义火花流接收器。它允许您从任何来源读取
于 2015-01-05T14:16:51.503 回答