A cluster-based streaming framework using Java and Akka - View it on GitHub