Consumes Kinesis stream, and channels logs to app drains - View it on GitHub