Теперь вы можете делать с этим val все, что хотите, как с Direct Streaming. Создать временное представление, выполнить SQL-запросы, что угодно ..
читал, что Spark Structured Streaming не поддерживает вывод схемы для чтения сообщений Kafka как JSON. Есть ли способ получить схему так же, как это делает Spark Streaming:
val dataFrame = spark.read.json(rdd.map(_.value()))
dataFrame.printschema