Kinesis Elasticsearch sink

Add a // TODO: move this to shared storage/shredding utils in due course