全部产品
Search

搜索本产品

    检索分析服务Elasticsearch版：通过Canal将MySQL数据同步到阿里云ES

    文档中心

    检索分析服务Elasticsearch版：通过Canal将MySQL数据同步到阿里云ES

    更新时间：Aug 19, 2026

    如果您需要将MySQL中的增量数据实时同步至阿里云Elasticsearch（简称ES）实例，且您对数据同步的实时性要求较高，可以通过Canal来实现。

    背景信息

    Canal是阿里巴巴集团提供的一个开源产品，能够通过解析数据库的增量日志，提供增量数据的订阅和消费功能。Canal的功能原理及详细说明请参见Canal。使用Canal模拟成MySQL的Slave，实时接收MySQL的增量数据binlog，然后通过RESTful API将数据写入到阿里云ES实例中，适用于对数据同步的实时性要求较高的场景。

    前提条件

    已创建RDS MySQL实例、阿里云ES实例、阿里云ECS实例。建议您在同一专有网络下创建相关实例。

    使用限制

    • 本方案仅支持将MySQL增量数据同步至阿里云ES。

    • 安装的JDK版本必须大于等于1.8.0。

    • Canal 1.1.4版本不支持ES 7.x版本。

      ES 7.x版本的数据写入需使用Canal 1.1.5版本，ES 8.x版本请选择1.1.7版本。您也可以通过其他方式（例如Logstash、DTS）实现MySQL数据同步。

    • 在进行数据同步时支持自定义索引Mapping，但需保证Mapping中定义的字段（名称+类型）与MySQL中一致。

    • 本方案需要您自行保证Canal的可用性，避免出现业务不可用或故障。例如：当出现ECS重启，Canal异常退出等场景时如何继续同步数据等。

    • Canal Adapter不支持使用HTTPS协议连接阿里云ES实例。

    操作步骤

    步骤一：准备MySQL数据源

    进入RDS控制台，创建RDS MySQL数据库和表。具体操作请参见RDS MySQL快速入门。本文使用的建表语句如下。

    -- create table
CREATE TABLE `es_test` (
    `id` bigint(32) NOT NULL,
    `name` text NOT NULL,
    `count` text NOT NULL,
    `color` text NOT NULL,
    PRIMARY KEY (`id`)
) ENGINE=InnoDB
DEFAULT CHARACTER SET=utf8;

    步骤二：创建索引

    1. 登录目标阿里云ES实例的Kibana控制台，具体操作请参见登录Kibana控制台。

      说明

      本文以阿里云ES 6.7.0版本为例，其他版本操作可能略有差别，请以实际界面为准。

    2. 在左侧导航栏，单击Dev Tools。

    3. 在Console中，执行以下命令创建索引。

      以下示例创建的索引名称为es_test，包含count、id、name和color字段。

      重要

      mappings中的字段需要与步骤一：准备MySQL数据源中创建的字段（名称和类型）保持一致。

      PUT es_test?include_type_name=true
{

    "settings" : {
      "index" : {
        "number_of_shards" : "5",
        "number_of_replicas" : "1"
      }
    },
    "mappings" : {
        "_doc" : {
            "properties" : {
              "count": {          
                   "type": "text"       
               },
              "id": {
                   "type": "integer"
               },
               "name": {
                    "type" : "text",
                    "analyzer": "ik_smart"                   
                },
                "color" : {
                    "type" : "text"                    
                }
            }
        }
    }
}

      创建成功后，返回如下结果。 

      {
  "acknowledged" : true,
  "shards_acknowledged" : true,
  "index" : "es_test"
}

    步骤三：安装JDK

    1. 连接ECS实例。

      具体操作请参见使用Workbench登录Linux实例。

      说明

      本文档以普通用户权限为例。

    2. 查看可用的JDK软件包列表。

      sudo yum search java | grep -i --color JDK

    3. 选择合适的版本，安装JDK。

      本文选择java-1.8.0-openjdk-devel.x86_64。 

      sudo yum install java-1.8.0-openjdk-devel.x86_64

    4. 配置环境变量。

      1. 打开etc文件夹下的profile文件。

        vim ~/.bash_profile

      2. 在文件内添加如下的环境变量。

        export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.362.b08-1.el7_9.x86_64
export CLASSPATH=.:$JAVA_HOME/jre/lib/rt.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export PATH=$PATH:$JAVA_HOME/bin
        重要

        JAVA_HOME需要替换为您JDK的安装路径，可通过find / -name 'java'命令查看。

      3. 按下Esc键，然后使用:wq保存文件并退出vi模式，随后执行以下命令使配置生效。

        source ~/.bash_profile

    5. 执行以下命令，验证JDK是否安装成功。

      java -version

      显示如下结果说明JDK安装成功。

      openjdk version "1.8.0_362"
OpenJDK Runtime Environment (build 1.8.0_362-b08)
OpenJDK 64-Bit Server VM (build 25.362-b08, mixed mode)

    步骤四：安装并启动Canal-server

    1. 下载Canal-server。

      本文使用1.1.4版本。 

      wget https://github.com/alibaba/canal/releases/download/canal-1.1.4/canal.deployer-1.1.4.tar.gz
      说明

      • 目前Canal 1.1.5版本已支持ES 7.0版本，如果您使用的是ES 7.0，需要下载Canal 1.1.5版本。详细信息请参见Canal release note。

      • 下载Canal-server和Canal-adapter需要连接公网，请确保ECS实例可以访问公网。

    2. 解压。

      tar -zxvf canal.deployer-1.1.4.tar.gz

    3. 修改conf/example/instance.properties文件。

      vi conf/example/instance.properties
      #################################################
## mysql serverId , v1.0.26+ will autoGen
# canal.instance.mysql.slaveId=0

# enable gtid use true/false
canal.instance.gtidon=false

# position info
canal.instance.master.address=rm-bpxxxd6ph.mysql.rds.aliyuncs.com:3306
canal.instance.master.journal.name=
canal.instance.master.position=
canal.instance.master.timestamp=
canal.instance.master.gtid=

# rds oss binlog
canal.instance.rds.accesskey=
canal.instance.rds.secretkey=
canal.instance.rds.instanceId=

# table meta tsdb info
canal.instance.tsdb.enable=true
#canal.instance.tsdb.url=jdbc:mysql://127.0.0.1:3306/canal_tsdb
#canal.instance.tsdb.dbUsername=canal
#canal.instance.tsdb.dbPassword=canal

#canal.instance.standby.address =
#canal.instance.standby.journal.name =
#canal.instance.standby.position =
#canal.instance.standby.timestamp =
#canal.instance.standby.gtid=

# username/password
canal.instance.dbUsername=xxx
canal.instance.dbPassword=xxx
canal.instance.connectionCharset = UTF-8
# enable druid Decrypt database password
canal.instance.enableDruid=false

      配置项

      说明

      canal.instance.master.address

      需要设置为<RDS MySQL数据库的内网地址>:<内网端口>，相关信息可在RDS MySQL实例的基本信息页面获取。例如rm-bp1u1xxxxxxxxx6ph.mysql.rds.aliyuncs.com:3306。

      canal.instance.dbUsername

      RDS MySQL数据库的账号名称，可在实例的账号管理页面获取。

      canal.instance.dbPassword

      RDS MySQL数据库的密码。

    4. 按下Esc键，然后使用:wq命令保存文件并退出vi模式。

    5. 启动Canal-server，并查看日志。

      ./bin/startup.sh
cat logs/canal/canal.log

      预期输出如下：

      [root@VM01 ~]# ./bin/startup.sh
cd to /root/bin for workaround relative path
LOG CONFIGURATION : /root/bin/../conf/logback.xml
canal conf : /root/bin/../conf/canal.properties
CLASSPATH :/root/bin/../conf:/root/bin/../lib/zookeeper-3.4.5.jar:/root/bin/../lib/zkclient-0.10.jar:/root/bin/../lib/spring-tx-3.2.18.RELEASE.jar:/root/bin/../lib/spring-orm-3.2.18.RELEASE.jar:/root/bin/../lib/spring-jdbc-3.2.18.RELEASE.jar:/root/bin/../lib/spring-expression-3.2.18.RELEASE.jar:/root/bin/../lib/spring-core-3.2.18.RELEASE.jar:/root/bin/../lib/spring-context-3.2.18.RELEASE.jar:/root/bin/../lib/spring-beans-3.2.18.RELEASE.jar:/root/bin/../lib/spring-aop-3.2.18.RELEASE.jar:/root/bin/../lib/snakeyaml-1.19.jar:/root/bin/../lib/slf4j-api-1.7.12.jar:/root/bin/../lib/simpleclient_pushgateway-0.4.0.jar:/root/bin/../lib/simpleclient_httpserver-0.4.0.jar:/root/bin/../lib/simpleclient_hotspot-0.4.0.jar:/root/bin/../lib/simpleclient_common-0.4.0.jar:/root/bin/../lib/simpleclient-0.4.0.jar:/root/bin/../lib/scala-reflect-2.11.12.jar:/root/bin/../lib/scala-logging_2.11-3.8.0.jar:/root/bin/../lib/scala-library-2.11.12.jar:/root/bin/../lib/rocketmq-srvutil-4.5.2.jar:/root/bin/../lib/rocketmq-remoting-4.5.2.jar:/root/bin/../lib/rocketmq-logging-4.5.2.jar:/root/bin/../lib/rocketmq-common-4.5.2.jar:/root/bin/../lib/rocketmq-client-4.5.2.jar:/root/bin/../lib/rocketmq-acl-4.5.2.jar:/root/bin/../lib/protobuf-java-3.6.1.jar:/root/bin/../lib/oro-2.0.8.jar:/root/bin/../lib/netty-tcnative-boringssl-static-1.1.33.Fork26.jar:/root/bin/../lib/netty-all-4.1.6.Final.jar:/root/bin/../lib/netty-3.2.2.Final.jar:/root/bin/../lib/mysql-connector-java-5.1.47.jar:/root/bin/../lib/metrics-core-2.2.0.jar:/root/bin/../lib/lz4-java-1.4.1.jar:/root/bin/../lib/logback-core-1.1.3.jar:/root/bin/../lib/logback-classic-1.1.3.jar:/root/bin/../lib/kafka-clients-1.1.1.jar:/root/bin/../lib/kafka_2.11-1.1.1.jar:/root/bin/../lib/jsr305-3.0.2.jar:/root/bin/../lib/jopt-simple-5.0.4.jar:/root/bin/../lib/jctools-core-2.1.2.jar:/root/bin/../lib/jcl-over-slf4j-1.7.12.jar:/root/bin/../lib/jackson-databind-2.9.6.jar:/root/bin/../lib/jackson-core-2.9.6.jar:/root/bin/../lib/jackson-annotations-2.9.0.jar:/root/bin/../lib/ibatis-sqlmap-2.3.4.726.jar:/root/bin/../lib/httpcore-4.4.3.jar:/root/bin/../lib/httpclient-4.5.1.jar:/root/bin/../lib/h2-1.4.196.jar:/root/bin/../lib/guava-18.0.jar:/root/bin/../lib/fastsql-2.0.0_preview_97.jar:/root/bin/../lib/fastson-1.2.58.jar:/root/bin/../lib/druid-1.1.9.jar:/root/bin/../lib/disruptor-3.4.2.jar:/root/bin/../lib/commons-logging-1.1.3.jar:/root/bin/../lib/commons-lang3-3.4.jar:/root/bin/../lib/commons-lang-2.6.jar:/root/bin/../lib/commons-io-2.4.jar:/root/bin/../lib/commons-compress-1.9.jar:/root/bin/../lib/commons-codec-1.9.jar:/root/bin/../lib/commons-cli-1.2.jar:/root/bin/../lib/commons-beanutils-1.8.2.jar:/root/bin/../lib/canal.store-1.1.4.jar:/root/bin/../lib/canal.sink-1.1.4.jar:/root/bin/../lib/canal.server-1.1.4.jar:/root/bin/../lib/canal.protocol-1.1.4.jar:/root/bin/../lib/canal.prometheus-1.1.4.jar:/root/bin/../lib/canal.parse.driver-1.1.4.jar:/root/bin/../lib/canal.parse.dbsync-1.1.4.jar:/root/bin/../lib/canal.parse-1.1.4.jar:/root/bin/../lib/canal.meta-1.1.4.jar:/root/bin/../lib/canal.instance.spring-1.1.4.jar:/root/bin/../lib/canal.instance.manager-1.1.4.jar:/root/bin/../lib/canal.instance.core-1.1.4.jar:/root/bin/../lib/canal.filter-1.1.4.jar:/root/bin/../lib/canal.deployer-1.1.4.jar:/root/bin/../lib/canal.common-1.1.4.jar:/root/bin/../lib/aviator-2.2.1.jar:/root/bin/../lib/aopalliance-1.0.jar::/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.71-2.b15.el7_2.x86_64/jre/lib/rt.jar:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.71-2.b15.el7_2.x86_64/lib/dt.jar:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.71-2.b15.el7_2.x86_64/lib/tools.jar
acd to /root for continue
[root@VM01 ~]# cat logs/canal/canal.log
2019-09-05 14:57:57.654 [main] INFO  com.alibaba.otter.canal.deployer.CanalLauncher - ## set default uncaught exception handler
2019-09-05 14:57:57.688 [main] INFO  com.alibaba.otter.canal.deployer.CanalLauncher - ## load canal configurations
2019-09-05 14:57:57.698 [main] INFO  com.alibaba.otter.canal.deployer.CanalStarter - ## start the canal server.
2019-09-05 14:57:57.732 [main] INFO  com.alibaba.otter.canal.deployer.CanalController - ## start the canal server[192.   4.192      234):11111]
2019-09-05 14:57:58.726 [main] INFO  com.alibaba.otter.canal.deployer.CanalStarter - ## the canal server is running now ......
[root@VM01 ~]#

    步骤五：安装并启动Canal-adapter

    1. 下载Canal-adapter。

      本文使用1.1.4版本。 

      wget https://github.com/alibaba/canal/releases/download/canal-1.1.4/canal.adapter-1.1.4.tar.gz
      说明

      • 目前Canal 1.1.5版本已支持ES 7.0版本，如果您使用的是ES 7.0，需要下载Canal 1.1.5版本。详细信息请参见Canal release note。

      • 下载Canal-server和Canal-adapter需要连接公网，请确保ECS实例可以访问公网。

    2. 解压。

      tar -zxvf canal.adapter-1.1.4.tar.gz

    3. 修改conf/application.yml文件。

      vi conf/application.yml
      server:
  port: 8081
spring:
  jackson:
    date-format: yyyy-MM-dd HH:mm:ss
    time-zone: GMT+8
    default-property-inclusion: non_null

canal.conf:
  mode: tcp # kafka rocketMQ
  canalServerHost: 127.0.0.1:11111
  batchSize: 500
  syncBatchSize: 1000
  retries: 0
  timeout:
  accessKey:
  secretKey:
  srcDataSources:
    defaultDS:
      url: jdbc:mysql://rm-******.mysql.rds.aliyuncs.com:3306/elasticsearch?useUnicode=true
      username: root
      password: ******
  canalAdapters:
  - instance: example
    groups:
    - groupId: g1
      outerAdapters:
      - name: logger
      - name: es
        hosts: es-cn-******.elasticsearch.aliyuncs.com:9200
        properties:
            mode: rest
            security.auth: elastic:******
            cluster.name: es-cn-******

      配置项

      说明

      canal.conf.canalServerHost

      canalDeployer访问地址。保持默认（127.0.0.1:11111）即可。

      canal.conf.srcDataSources.defaultDS.url

      需要设置为jdbc:mysql://<RDS MySQL内网地址>:<内网端口>/<数据库名称>?useUnicode=true，相关信息可在RDS MySQL实例的基本信息页面获取。例如jdbc:mysql://rm-bp1xxxxxxxxxnd6ph.mysql.rds.aliyuncs.com:3306/elasticsearch?useUnicode=true。

      canal.conf.srcDataSources.defaultDS.username

      RDS MySQL数据库的账号名称，可在RDS MySQL实例的账号管理页面获取。

      canal.conf.srcDataSources.defaultDS.password

      RDS MySQL数据库的密码。

      canal.conf.canalAdapters.groups.outerAdapters.hosts

      定位到name:es的位置，将hosts替换为<ES实例的内网地址>:<内网端口>，相关信息可在ES实例的基本信息页面获取。例如，es-cn-v64xxxxxxxxx3medp.elasticsearch.aliyuncs.com:9200。

      canal.conf.canalAdapters.groups.outerAdapters.mode

      必须设置为rest。

      canal.conf.canalAdapters.groups.outerAdapters.properties.security.auth

      需要设置为<ES实例的账号>:<密码>。例如elastic:es_password。

      canal.conf.canalAdapters.groups.outerAdapters.properties.cluster.name

      ES实例的ID，可在ES实例的基本信息页面获取。例如es-cn-v64xxxxxxxxx3medp。

    4. 按下Esc键，然后使用:wq命令保存文件并退出vi模式。

    5. 同样的方式，修改conf/es/*.yml文件，定义MySQL数据到ES数据的映射字段。

      dataSourceKey: defaultDS
destination: example
groupId: g1
esMapping:
  _index: es_test
  _type: _doc
  _id: _id
  #pk: id
  sql: "select t.id as _id,t.id,t.count,t.name,t.color from es_test t"
  commitBatch: 3000

      配置项

      说明

      esMapping._index

      步骤二：创建索引章节中，在ES实例中所创建的索引的名称。本文使用es_test。

      esMapping._type

      步骤二：创建索引章节中，在ES实例中所创建的索引的类型。本文使用_doc。

      esMapping._id

      需要同步到ES实例的文档的id，可自定义。本文使用_id。

      esMapping.sql

      SQL语句，用来查询需要同步到ES中的字段。本文使用select t.id as _id,t.id,t.count,t.name,t.color from es_test t。

    6. 启动Canal-adapter服务，并查看日志。

      ./bin/startup.sh
cat logs/adapter/adapter.log
      说明

      本文以MySQL 5.7版本为例，如果您使用的是MySQL其它版本，需要将MySQL驱动器替换为相应的版本，否则可能会导致启动失败，详细信息请参见常见问题。

      日志中出现 ## ES mapping config loaded 和 ## the canal client adapters are running now ...... 表示 Canal adapter 启动成功，预期日志输出：

      2019-09-05 20:16:22.918 [Thread-2] INFO  com.alibaba.druid.pool.DruidDataSource - {dataSource-2} inited
2019-09-05 20:16:24.928 [Thread-2] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterService - ## start the canal client adapters.
2019-09-05 20:16:24.929 [Thread-2] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterLoader - Load canal adapter: logger succeed
2019-09-05 20:16:24.929 [Thread-2] INFO  c.a.o.canal.client.adapter.es.config.ESSyncConfigLoader - ## Start loading es mapping config ...
2019-09-05 20:16:24.943 [Thread-2] INFO  c.a.o.canal.client.adapter.es.config.ESSyncConfigLoader - ## ES mapping config loaded
2019-09-05 20:16:25.182 [Thread-2] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterLoader - Load canal adapter: es succeed
2019-09-05 20:16:25.185 [Thread-2] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterLoader - Start adapter for canal instance: example succeed
2019-09-05 20:16:25.185 [Thread-2] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterService - ## the canal client adapters are running now ......
2019-09-05 20:16:25.185 [Thread-2] INFO  c.a.o.c.a.launcher.monitor.ApplicationConfigMonitor - ## adapter application config reloaded.
2019-09-05 20:16:25.186 [Thread-8] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Start to connect destination: example <=============
2019-09-05 20:16:25.186 [Thread-8] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Start to subscribe destination: example <=============
2019-09-05 20:16:25.232 [Thread-8] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Subscribe destination: example succeed <=============
2019-09-05 20:16:27.432 [pool-5-thread-1] INFO  c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":null,"type":"mysql","destination":"example","es":1,"sql":"/* rds internal mark */ CREATE TABLE IF NOT EXISTS mysql.ha_health_check (\n  id   BIGINT  DEFAULT 0,\n  type CHAR(1) DEFAULT '0',\n  PRIMARY KEY (type)\n)\n/*CREATE*/"}

    步骤六：验证增量数据同步

    1. 在RDS MySQL数据库中，新增、修改或删除数据库中es_test表的数据。

      insert `ES`.`es_test`(`count`,`id`,`name`,`color`) values('11',2,'canal_test2','red');

    2. 登录目标阿里云ES实例的Kibana控制台，具体操作请参见登录Kibana控制台。

    3. 在左侧导航栏，单击Dev Tools。

    4. 在Console中，执行以下命令查询同步成功的数据。

      GET /es_test/_search

      预期结果如下。

      GET /es_test/_search

{
  "took" : 1,
  "timed_out" : false,
  "_shards" : {
    "total" : 5,
    "successful" : 5,
    "skipped" : 0,
    "failed" : 0
  },
  "hits" : {
    "total" : 1,
    "max_score" : 1.0,
    "hits" : [
      {
        "_index" : "es_test",
        "_type" : "_doc",
        "_id" : "2",
        "_score" : 1.0,
        "_source" : {
          "id" : 2,
          "count" : "11",
          "name" : "canal_test2",
          "color" : "red"
        }
      }
    ]
  }
}
      重要

      Canal同步的是增量数据，不会同步之前的存量数据。

    常见问题

    Q：启动Canal-adapter时，adapter.log日志显示异常，如何解决？错误日志为：java.lang.RuntimeException: java.lang.RuntimeException: java.lang.ClassCastException: com.alibaba.druid.pool.DruidDataSource cannot be cast to com.alibaba.druid.pool.DruidDataSource

    at com.alibaba.otter.canal.client.adapter.es7x.ES7xAdapter.init(ES7xAdapter.java:54) ~[client-adapter.es7x-1.1.5-jar-with-dependencies.jar:na]

    A：将canal.adapter-1.1.5\plugin下的client-adapter.es7x-1.1.5-jar-with-dependencies.jar替换为canal-1.1.5-alpha-2版本下的对应文件。

    说明

    您可以参考Canal的issues解决，请参见Canal issues

    以root权限用户为例，操作步骤如下：

    1. 下载canal-1.1.5-alpha-2版本。详细信息请参见Canal release note。

      wget https://github.com/alibaba/canal/releases/download/canal-1.1.5-alpha-2/canal.adapter-1.1.5-SNAPSHOT.tar.gz

    2. 解压文件。

      tar -zxvf canal.adapter-1.1.5-SNAPSHOT.tar.gz

    3. 拷贝canal-1.1.5-alpha-2 版本中plugin下的client-adapter.es7x-1.1.5-SNAPSHOT-jar-with-dependencies.jar放到canal.adapter-1.1.5\plugin目录下。

      说明

      实际拷贝文件的目录需根据您创建的目录结构来。

      cp canal.adapter-1.1.5-SNAPSHOT/plugin/client-adapter.es7x-1.1.5-SNAPSHOT-jar-with-dependencies.jar canal/canal.adapter/plugin

    4. 删除canal.adapter-1.1.5\plugin下的client-adapter.es7x-1.1.5-jar-with-dependencies.jar。

      rm -rf client-adapter.es7x-1.1.5-jar-with-dependencies.jar

    5. 修改名字。

      mv client-adapter.es7x-1.1.5-SNAPSHOT-jar-with-dependencies.jar client-adapter.es7x-1.1.5-jar-with-dependencies.jar

    Q：启动Canal-adapter时，adapter.log日志显示异常，如何解决？错误日志为java.sql.SQLException: Unknown system variable 'query_cache_size'

    A：可能是由于Canal-adapter中自带的MySQL驱动版本与连接的MySQL数据库版本不一致导致，例如：使用的canal.adapter-1.1.4时，其自带的MySQL驱动器为mysql-connector-java-5.1.40.jar，在连接MySQL8时就会出现如上所述的异常信息。可更换Canal-adapter中的MySQL驱动器版本进行解决。

    Q：使用Canal同步MySQL 8.0版本的数据，如何将MySQL驱动器版本替换成8.0？

    A：以下操作步骤以root权限用户为例。

    1. 下载8.0版本的MySQL驱动器。

      wget https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-8.0.29.zip

    2. 解压。

      unzip mysql-connector-java-8.0.29.zip

    3. 拷贝文件到Canal-adapter的lib目录下。

      mv mysql-connector-java-8.0.29/mysql-connector-java-8.0.29.jar lib/

    4. 添加权限。

      chmod 777 lib/mysql-connector-java-8.0.29.jar
chmod +st lib/mysql-connector-java-8.0.29.jar

    5. 删除5.x版本的驱动器。

      rm -rf lib/mysql-connector-java-5.1.40.jar

    相关文档