Я пытаюсь настроить простой процесс с помощью Spark Streaming, используя Apache Bahir для подключения к Akka. Я попытался следовать their example вместе с этим older one. У меня есть простой форвардер
Я пытаюсь подключить ApacheSpark Structured Stream к теме MQTT (платформа IBM Watson IoT на IBM Bluemix в этом случае). Я создаю структурированный поток следующим образом: val df = spark.readStream