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