I am trying to connect to my Kafka from spark but getting an error Kafka Version: 2.4.1 Spark Version: 3.3.0
I am using jupyter notebook to execute the pyspark code below:
from pyspark.sql.functions import *
from pyspark.sql.types import *
#import library
import os
from pyspark.sql import SparkSession
os.environ['PYSPARK_SUBMIT_ARGS'] = '--packages
…
Top comments (0)