consume kinesis stream of events, apply grok filter, and then store in elasticsearch - View it on GitHub