Canal简述:

Canal是阿里开源的一款基于Mysql数据库binlog的增量订阅和消费组件,通过它可以订阅数据库的binlog日志,然后进行一些数据消费。

Canal安装前准备工作:

1、安装配置好MySql,如果不会安装可以跳转到Linux安装MySQL(保姆级教程)

2、使用xftp将Canal安装包上传到虚拟机中
canal.deployer-1.1.5.tar.gz

Canal安装操作步骤:

1、首先开启binlog,修改mysql配置文件my.cnfvim /etc/my.cnf(已注明行号)

 14 server-id=1
 15 log-bin=mysql-bin
 16 binlog_format=row
 17 binlog-do-db=cananstu
 18 max_allowed_packet=1024M

2、重启mysql服务systemctl restart mysqld,到数据目录下查看是否生成了binlog文件。
在这里插入图片描述
3、在mysql中给canal配置权限

grant select,replication slave, replication client on *.* to 'canal'@'%' identified by 'canal';

如果提示安全性
ERROR 1819 (HY000): Your password does not satisfy the current policy requirements的话,
需要去设置一下。

set global validate_password_length=4;
set global validate_password_policy=0;

4、解压缩文件
先创建一个目录,用于存放解压缩后的安装包mkdir -p /opt/soft/canal
tar -zxf canal.deployer-1.1.5.tar.gz -C ../soft/canal/

5、修改配置文件
进入到canal的conf目录下,修改配置文件canal.propertiesvim canal.properties(已注明行号)版本不同可能会导致行数不同,但内容都是一样的

29 canal.serverMode = kafka
140 kafka.bootstrap.servers = ip地址:9092

进入到conf目录下的example目录,修改配置文件instance.propertiesvim instance.properties(已注明行号)版本不同可能会导致行数不同,但内容都是一样的

3 canal.instance.mysql.slaveId=10
9 canal.instance.master.address=ip地址:3306
33 canal.instance.dbUsername=canal
34 canal.instance.dbPassword=canal
35 canal.instance.connectionCharset = UTF-8
50 canal.mq.topic=canalkfdemo

6、启动canal
进入到canal目录下,执行命令./bin/startup.sh
使用jps查看进程
在这里插入图片描述

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐