從Mysq了中導入數據到Elasticsearch中

公司業務在中途由於數據庫的壓力，要將之前的搜索從DB中查詢修改爲Elasticsearch中 想法是提供jar 在數據新增和修改的地方調用jar中方法，寫入kafka中，再使用consumer 寫入ES，爲了不造成數據重複，使用主鍵ID做upert操作 目前流程已經開發完成，查詢接口和分詞都完成，最後工作是將歷史數據從DB中(MYSQL)中最終寫入到ES中 有三種方案 ： 第一種：寫程序，鏈接MY

>>阅读原文<<