spark streaming kafka assembly_2.111.6.3.jar Apache Kafka作为DStream数据源,spark使用流处理处理kafka数据的时候需要将本jar包导入venv/lib/python3.7/site-packages/pyspark/jars
sparkstreamingkafka08_2.112.4.5.jar ApacheKafka作为DStream数据源,Pyspark中在使用流处理的方式处理kafka数据时需要将本jar包导入venv/lib/python3.7/site-packages/pyspark/jars下