Motivation behind this project is to explore Flink streaming API and run jobs to perform transformation on datastreams
Kafka ---> Flink ----> tasks: Create Flink job to consume data stream from Kafka. Perform functions on data streams, windows. Save data to Mongo