从Mysq了中导入数据到Elasticsearch中

公司业务在中途由于数据库的压力，要将之前的搜索从DB中查询修改为Elasticsearch中 想法是提供jar 在数据新增和修改的地方调用jar中方法，写入kafka中，再使用consumer 写入ES，为了不造成数据重复，使用主键ID做upert操作 目前流程已经开发完成，查询接口和分词都完成，最后工作是将历史数据从DB中(MYSQL)中最终写入到ES中 有三种方案 ： 第一种：写程序，链接MY

>>阅读原文<<