DEV Community

Avnis Singh
Avnis Singh

Posted on

Spark Version 3.3.0 connect with kafka

0

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)