Even I'm learning the concept of Apache Spark. Feel free to update the repo.
The consumer will just dump whatever its on the bus on to the terminal.
brew install spark
brew install kafka
brew services start zookeeper
brew services start kafka
go to your apache-spark/1.6.1/libexec folder
./sbin/start-master.sh
the .out
file should say Starting Spark master at spark://${your_computer_name}:7077
./sbin/start-slave.sh spark://${name_of_your_master}
the last line of the .out
file should be Successfully registered with master spark://${your_computer_name}:7077
go to Simple_Spark-Kafka_Consumer/spark1/twitter
mvn clean
mvn install
go to target folder spark-submit --class kafka_consumer.twitter.App --master spark://localhost:7077 twitter-0.0.1-SNAPSHOT-jar-with-dependencies.jar
To execute, the jar needs to be submitted to spark.