kafka同步到Elasticsearch

+] 一、kafka同步到Elasticsearch方式？ 目前已知經常使用的方式有四種： 1）logstash_input_kafka插件； 缺點：不穩定（ES中文社區討論） 2）spark stream同步； 缺點：太龐大 3）kafka connector同步； 4）自寫程序讀取、解析、寫入 本文主要基於kafka connector實現kafka到Elasticsearch全量、增量同步。

>>阅读原文<<