Hello Burak,
Sorry to the delayed answer, you were right.
1) - I change the sql-kafka connector version and fixed.
2) - The propose was just test, and I was using normal streaming also for
other thing.
I'm was wondering how did you know was the sql-kafka connector version
reading the logs. I Co
Hi Daniel,
Several things:
1) Your error seems to suggest you're using a different version of Spark
and a different version of the sql-kafka connector. Could you make sure
they are on the same Spark version?
2) With Structured Streaming, you may remove everything related to a
StreamingContext.