org.apache.spark.streaming.kafka.KafkaUtils
is in the
spark-streaming-kafka-0-8
project
On Mon, Jun 19, 2017 at 1:01 PM, karan alang wrote:
> Hi Cody - i do have a additional basic question ..
>
> When i tried to compile the code in Eclipse, i was not able to do that
>
> eg.
> import org.apache.s
Hi Cody - i do have a additional basic question ..
When i tried to compile the code in Eclipse, i was not able to do that
eg.
import org.apache.spark.streaming.kafka.KafkaUtils
gave errors saying KafaUtils was not part of the package.
However, when i used sbt to compile - the compilation went th
Thanks, Cody .. yes, was able to fix that.
On Sat, Jun 17, 2017 at 1:18 PM, Cody Koeninger wrote:
> There are different projects for different versions of kafka,
> spark-streaming-kafka-0-8 and spark-streaming-kafka-0-10
>
> See
>
> http://spark.apache.org/docs/latest/streaming-kafka-integration
There are different projects for different versions of kafka,
spark-streaming-kafka-0-8 and spark-streaming-kafka-0-10
See
http://spark.apache.org/docs/latest/streaming-kafka-integration.html
On Fri, Jun 16, 2017 at 6:51 PM, karan alang wrote:
> I'm trying to compile kafka & Spark Streaming int
I'm trying to compile kafka & Spark Streaming integration code i.e. reading
from Kafka using Spark Streaming,
and the sbt build is failing with error -
[error] (*:update) sbt.ResolveException: unresolved dependency:
org.apache.spark#spark-streaming-kafka_2.11;2.1.0: not found
Scala version