Я пытаюсь подключить структурированный поток ApacheSpark к теме MQTT (в данном случае IBM Watson IoT Platform на IBM Bluemix). Я создаю структурированный поток следующим образом: val df = spark.readStream...

Когда я запустил искровую оболочку с помощью следующей команды bin/spark-shell --packages org.apache.bahir:spark-streaming-mqtt_2.11:2.3.0 --repositories http://central.maven.org/maven2/org/apache/bahir/spark-streaming-mqtt_2.11/2.3.0/...