SCALA + SPARK + KAFKA
- sbt
- Scala 2.12.8
- kafka-2.12-2.2.1
- bash
- Java 8
- Internet Connection
Each of these scripts launch required part for the project demonstration.
- Run Zookeeper Kafka (only once by computer boot)
./master.sh
- Run producer
./run_consumer.sh
- Run Consumer
./run_producer.sh
Result of spark streaming stored in stream/
./run_web.sh
Scala Producer of Drones Messages
|
|
V
Kafka
|
|
V
Spark Streaming
|
|
V
Files in (stream/) (Not HDFS)
|
|
V
FrontEnd/Backend (Web Site)
1 topic : "msg"