Springboot连接Canal相关问题记录

一,研究 CanalConnector 的用户与哪个配置有关

a. 修改 mysql 用户密码;

alter user ‘canal’@’%’ identified by ‘123456’; (FLUSH PRIVILEGES;?

b. 新建实例, 只要conf/ 创建同名目录即可,同时拷instance.properties到目录下,即可;

配置 instance.properties

canal.instance.dbUsername = canal

canal.instance.dbPassword = 123456

/bin/开启 startup.bat

c. spring 客户代码连接; — 连接成功;

客户代码连接使用的用户密码,与 instance.properties 的 canal.instance.dbUsername[dbPassword] 有关;

与 canal.properties 无关;

d. 将 mysql 的canal用户密码改掉; — 程序 代码还是能正常侦听到insert 的日志; (尽量与mysql的一样)

二,canal密码加密方式问题

mysql 用户密码加密方式问题,需要改为canal的 mysql_native_password;

三,canal优化参考:

https://cloud.tencent.com/developer/article/1645881

四,集群参考:

https://blog.csdn.net/sinat_27818621/article/details/121357499

五,遇到 connect by peer 的错误

有可能是当前 canal 运行的日志文件或 position 与 canal server 的不一致;

停止 canal server ,删除日志,删除 meta.bat, 修改 instance下 instance.properties 日志及 position ,重启;

执行 insert 操作 (有可能还是看不到日志,有可能是被 其他服务实例吃了);

欢迎您的到来,感谢您的支持!

为您推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用 * 标注