项目官方地址:
[canal_wiki]: https://github.com/alibaba/canal/wiki “canal官方项目地址”
canal必须要开启mysql Binlog,开启方式如下:
对于自建 MySQL , 需要先开启 Binlog 写入功能,配置 binlog-format 为 ROW 模式,my.cnf 中配置如下:
[mysqld]
log-bin=mysql-bin # 开启 binlog
binlog-format=ROW # 选择 ROW 模式
server_id=1 # 配置 MySQL replaction 需要定义,不要和 canal 的 slaveId 重复
授权 canal 链接 MySQL 账号具有作为 MySQL slave 的权限, 如果已有账户可直接 grant:
CREATE USER canal IDENTIFIED BY ‘xxxxxx’;
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON . TO ‘canal‘@’%’;
– GRANT ALL PRIVILEGES ON . TO ‘canal‘@’%’ ;
FLUSH PRIVILEGES;
canal数据同步到rabbitmq的配置
vim ./services/canal/conf/canal.properties
修改如下配置:
# tcp, kafka, rocketMQ, rabbitMQ, pulsarMQ
canal.serverMode = rabbitMQ
##################################################
######### RabbitMQ #############
##################################################
rabbitmq.host = 192.168.0.21
rabbitmq.virtual.host = message
rabbitmq.exchange = direct.exchange
rabbitmq.username = whrp_mq
rabbitmq.password = xxxxxxxxxx
rabbitmq.deliveryMode = 2
以上配置,根据实际情况修改
vim ./services/canal/conf/example/instance.properties
# position info, 数据的地址
canal.instance.master.address=192.168.0.21:3306
# username/password, 数据库的账号密码
canal.instance.dbUsername=canal
canal.instance.dbPassword=xxxxx
# table regex, 监听的数据库表
canal.instance.filter.regex=dossier.case_info,dossier.file_info,dossier.storage_file
常见问题以及解决方法:
作者:zhaixiaoqing 创建时间:2023-04-14 16:24
最后编辑:admin 更新时间:2023-12-26 09:59
最后编辑:admin 更新时间:2023-12-26 09:59