Spark – consumer from Kafka

This tutorial illustrate how to consume messages from kafka using spark shell. Lets start installing kafka:

At this point kafka is up and runnig. Create a new sbt project, edit *.sbt and add the following lines

Then

Now copy the following jars

Start spark shell

On another shell, create kafka.scala […]