我正在使用PySpark读取一些数据,我正在尝试从Kafka源代理程序读取数据,但PySpark中没有打印结果 .

我意识到Kafka发送和接收方法正如预期和消费者所期望的那样工作 . 问题是读取经纪人在PySpark发送的数据

这是我的代码,

events = spark.readStream.format("kafka").option("kafka.bootstrap.servers", "localhost:9092").option("subscribe", "kafka_stream").option("startingOffsets", "latest").load()

events.selectExpr("CAST(key AS STRING)", "CAST(value AS STRING)","topic")

events.writeStream().outputMode("append").format("console").start()

正如我所说,屏幕上没有打印记录 . 但是当我使用套接字格式时,它正常工作 .