Kafka create stream运行但不打印Pyspark中Kafka主题的处理输出

from pyspark.sql import SparkSession

spark = SparkSession.builder.appName("KafkaStream").getOrCreate()
spark.sparkContext.setLogLevel("INFO")

from pyspark.sql import SparkSession
from pyspark.streaming import StreamingContext

spark = SparkSession.builder.appName("KafkaStream").getOrCreate()
spark.sparkContext.setLogLevel("INFO")

# 创建StreamingContext
ssc = StreamingContext(spark.sparkContext, batchDuration=5)

# 设置Kafka参数
kafkaParams = {
  "bootstrap.servers": "kafka_server:9092",
  "subscribe": "topic_name",
  "group.id": "consumer_group"
}

# 创建Kafka数据流
kafkaStream = KafkaUtils.createDirectStream(ssc, kafkaParams)

# 处理每个批次的数据
kafkaStream.foreachRDD(processRDD)

# 启动StreamingContext
ssc.start()
ssc.awaitTermination()