ElasticSearch实战（四十三）-Logstash 官方数据离线同步方案

Posted 2021-10-11 张志翔ۤ

        在上文中，我们提到了三种离线数据同步方案，Logstash 是轻量级数据离线同步方案的一种，为什么我们说它是轻量级而不是重量级？因为 Logstash 他适合处理单数据源的简单数据结构的数据清洗和转换，在处理复杂数据源和复杂数据结构它并不是很合适，Logstash官方可支持多种数据源的数据离线同步，图示如下：

        我就给一个mysql数据通过Logstash同步到ElasticSearch中的案例供大家操作。

一、安装logstash并同步MySQL数据库

        1、下载logstash

        下载的版本要和你的elasticsearch的版本号一致，我的版本elasticsearch7.11.1

        2、配置logstash-jdbc-input

        据说2.x以上就不用配置了，不过我还是配置了

        3、添加mysql-connector驱动jar包

        把这个jar包放入logstash中：mysql-connector-java-5.1.21.jar

        4、添加配置文件（用于连接elasticsearch和mysql数据库）很重要！

        具体的解释推荐博客：