Kinesis Elasticsearch sink

Move this into a private helper function