磚

從pyspark。sql進口SparkSession scala_version = ' 2.12 ' spark_version = = [f 'org.apache 3.3.0的包。火花:spark-sql-kafka-0-10_ {scala_version}: {spark_version}”、“org.apache.kafka: kafka-clients: 3.2.1 '] = SparkSession.bui火花……