我正在阅读来自kafka主题的消息 messageDFRaw = spark.readStream\
.format("kafka")\message": "cool"}| 如何从DataStreamReader创建数据框,使其具有列作为|key|channel| username| message|的数据框 我尝试按照How to readrecords in JSON format from <
我正在尝试将json消息从Kafka主题读取到PySpark数据帧中。)我想知道有没有办法使用Sparkstructuredstreaming或类似的方法来获得相同的数据帧Please deploy the application as per the deployment section of "Structured</