Stream in and out of Elasticsearch