Real-time-Stocks-Big-Data-pipeline Data Transportation: Kafka; Storage: Cassandra; Processing: Spark; System corporation: Zookeeper; Task Scheduling: Mesos. data-producer.py (get Stock prices every 1s from google finance API, send it to Kafka.)
