Spark-Kafka Integration | spark-submit giving errors |

20 views Asked by At

I have written a program in Python for reading data(spark.readStream) from kafkatopic and writing it into a parquet file. While submitting the program I'm receiving classNotFound error even though I have mentioned all the jars required and every jar has been added properly.

This is the code I have written: This is the code I have written The error which I'm receiving

0

There are 0 answers