Wrapper around our Kinesis event stream to keep format consistent - View it on GitHub