Actually, i've 2 versions of Kafka (0.9 & 0.10) ..
btw, i was able to resolve the issue ..
sbt by default considers src/main/scala as default source location,
I'd changed the location to a different one.
I changed the build.sbt to point to the required location, that fixed the
issue
regds,
Karen,
It looks like the Kafka version is incorrect. You mention Kafka 0.10
however the classpath references Kafka 0.9
Thanks,
David
On July 10, 2017 at 1:44:06 PM, karan alang (karan.al...@gmail.com) wrote:
Hi All,
I'm running Spark Streaming - Kafka integration using Spark 2.x & Kafka 10.
Hi All,
I'm running Spark Streaming - Kafka integration using Spark 2.x & Kafka 10.
& seems to be running into issues.
I compiled the program using sbt, and the compilation went through fine.
I was able able to import this into Eclipse & run the program from Eclipse.
However, when i run the
