A Scala & Akka based implementation for working with Amazon Kinesis Streams