Я пишу DStream в Elasticsearch, используя соединитель Elasticsearch-Hadoop.По этой ссылке вы можете...