Kinesis Elasticsearch sink

You could build the ADT here