1.环境准备：1.1 mysql:5.71.2 elasticsearch:7.4.21.3 kibana:7.4.21.4服务端：canal-deployer1.1.51.5客户端：canal-adapter1.1.52.下载安装MySQL（注：本人项目都是docker安装 这里就不一一展示安装步骤了 详情见百度或者看我其他文章）修改mysql配置文件开启binlog日志,并且以ROW方式,开启主从模式以及logbin的文件位置如下：server_id=101binlog-ignore-db=mysqllog-bin=mall-mysql-binbinlog_cache_size=1Mbi
1.环境准备：1.1 mysql:5.71.2 elasticsearch:7.4.21.3 kibana:7.4.21.4服务端：canal-deployer1.1.51.5客户端：canal-adapter1.1.52.下载安装MySQL（注：本人项目都是docker安装 这里就不一一展示安装步骤了 详情见百度或者看我其他文章）修改mysql配置文件开启binlog日志,并且以ROW方式,开启主从模式以及logbin的文件位置如下：server_id=101binlog-ignore-db=mysqllog-bin=mall-mysql-binbinlog_cache_size=1Mbi
简介以下关于Canal的介绍来自Github官方介绍。canal[kə'næl]，译意为水道/管道/沟渠，主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。工作原理canal模拟MySQLslave的交互协议，将自己伪装为MySQLslave，向MySQLmaster发送dump协议。MySQLmaster收到dump请求，开始推送binarylog给slave（即canal）。canal解析binarylog对象（原始为byte流）。因此可以使用Canal来提供MySQL数据库增量数据的订阅和消费，当MySQL数据库中的数据发生变化时，Canal可以高效地将这些数据同步到下
简介以下关于Canal的介绍来自Github官方介绍。canal[kə'næl]，译意为水道/管道/沟渠，主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。工作原理canal模拟MySQLslave的交互协议，将自己伪装为MySQLslave，向MySQLmaster发送dump协议。MySQLmaster收到dump请求，开始推送binarylog给slave（即canal）。canal解析binarylog对象（原始为byte流）。因此可以使用Canal来提供MySQL数据库增量数据的订阅和消费，当MySQL数据库中的数据发生变化时，Canal可以高效地将这些数据同步到下
##【问题描述】开发有天碰到一个很奇怪的问题，他的场景是这样子的：通过Canal来订阅MySQL的binlog,当捕获到有数据变化时，回到数据库，反查该数据的明细，然后做进一步处理。有一次，他碰到一个诡异的现象：1.Canal收到消息，有一条主键id=31019319的数据插入2.1
##【问题描述】开发有天碰到一个很奇怪的问题，他的场景是这样子的：通过Canal来订阅MySQL的binlog,当捕获到有数据变化时，回到数据库，反查该数据的明细，然后做进一步处理。有一次，他碰到一个诡异的现象：1.Canal收到消息，有一条主键id=31019319的数据插入2.1
##【问题描述】开发有天碰到一个很奇怪的问题，他的场景是这样子的：通过Canal来订阅MySQL的binlog,当捕获到有数据变化时，回到数据库，反查该数据的明细，然后做进一步处理。有一次，他碰到一个诡异的现象：1.Canal收到消息，有一条主键id=31019319的数据插入2.1
##【问题描述】开发有天碰到一个很奇怪的问题，他的场景是这样子的：通过Canal来订阅MySQL的binlog,当捕获到有数据变化时，回到数据库，反查该数据的明细，然后做进一步处理。有一次，他碰到一个诡异的现象：1.Canal收到消息，有一条主键id=31019319的数据插入2.1
一、简介canal[kə'næl]，译意为水道/管道/沟渠，主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。早期阿里巴巴因为杭州和美国双机房部署，存在跨机房同步的业务需求，实现方式主要是基于业务trigger获取增量变更。从2010年开始，业务逐步尝试数据库日志解析获取增量变更进行同步，由此衍生出了大量的数据库增量订阅和消费业务。Canal是用Java开发的基于数据库增量日志解析，提供增量数据订阅&消费的中间件。目前，Canal主要支持了MySQL的Binlog解析，解析完成后才利用CanalClient来处理获得的相关数据。（数据库同步需要阿里的Otter中间件，基于Ca
一、简介canal[kə'næl]，译意为水道/管道/沟渠，主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。早期阿里巴巴因为杭州和美国双机房部署，存在跨机房同步的业务需求，实现方式主要是基于业务trigger获取增量变更。从2010年开始，业务逐步尝试数据库日志解析获取增量变更进行同步，由此衍生出了大量的数据库增量订阅和消费业务。Canal是用Java开发的基于数据库增量日志解析，提供增量数据订阅&消费的中间件。目前，Canal主要支持了MySQL的Binlog解析，解析完成后才利用CanalClient来处理获得的相关数据。（数据库同步需要阿里的Otter中间件，基于Ca
