Kinesis Elasticsearch sink

Add a // TODO: move out into a kinesis helpers library