Canal —— 一款 MySql 实时同步到 ES 的阿里开源神器

Canal 是一个基于 MySQL 数据库增量日志解析的开源工具，它的设计目的是提供低延迟的数据变更监测服务。

以下是一个简单的使用 Canal 将 MySql 数据实时同步到 Elasticsearch 的例子：

1. 确保你的 MySql 开启了 binlog，设置 binlog_format=row。
2. 下载并配置 Canal。
3. 配置 Elasticsearch 输出插件。
4. 启动 Canal 服务。

以下是一个简单的示例配置：

<canal>
    <!-- 服务端的端口 -->
    <port>11111</port>
    <!-- 实例的目录 -->
    <dir>./conf</dir>
    <!-- 数据库地址 -->
    <spring.datasource.url>jdbc:mysql://127.0.0.1:3306</spring.datasource.url>
    <!-- MySQL 用户名 -->
    <spring.datasource.username>canal</spring.datasource.username>
    <!-- MySQL 密码 -->
    <spring.datasource.password>canal</spring.datasource.password>
    <!-- 同步的数据库 -->
    <spring.datasource.dbName>test</spring.datasource.dbName>
 
    <!-- 输出插件配置 -->
    <canal.instance.tsdb>
        <!-- 使用 Elasticsearch -->
        <type>elasticsearch</type>
        <!-- Elasticsearch 地址 -->
        <es.cluster.name>my-cluster-name</es.cluster.name>
        <es.cluster.nodes>127.0.0.1:9300</es.cluster.nodes>
        <!-- 索引的设置 -->
        <es.index.name>my_index</es.index.name>
        <es.index.type>my_type</es.index.type>
        <es.version>5.6.16</es.version>
        <es.client.transportSniffer>true</es.client.transportSniffer>
    </canal.instance.tsdb>
</canal>

以上配置了 Canal 监听 MySQL 的 test 数据库，并将变更数据实时同步到 Elasticsearch 的 my_index 索引中。

启动 Canal 服务后，它会自动解析 binlog 日志，将数据变更捕获后，按照配置同步到指定的数据存储系统。

注意：以上配置仅为示例，实际配置可能需要根据你的环境进行相应的调整。