DynamoDB River for ElasticSearch using update streams API