我在spark的POM.xml中添加了依赖项，在以下链接中给出：
http://bahir.apache.org/docs/spark/current/spark-sql-streaming-mqtt/
再次使用 Maven 构建 Spark。但我们可以看到，它仅显示 Java 和 Scala 支持从 mqtt 获取数据。
我想从python 中的 mqtt 获取流数据。 在早期版本中，我们有一个 pyspark.streaming.mqtt 来实现相同的目的。Spark 2.2.0 pyspark中与此类似的是什么？我正在使用 mosquitto 作为 mqtt 代理。