canal使用过程中的报错

canal使用过程中的报错

报错1:canal和mysql的交互

解释:本质原因是因为同一个IP在短时间内产生太多中断的数据库连接（超过max_connect_errors的最大值）而导致的）

如果MySQL服务器连续接收到了来自于同一个主机的请求，而且这些连续的请求全部都没有成功,建立的连接就被中断了，当这些连续的请求的累计值大于max_connect_errors的设定值时，MySQL服务器就会阻止这台主机后续的所有请求。

解决办法:  mysqladmin flush-hosts -h 127.0.0.1 -uroot -p密码

详情戳这里:  MySQL参数max_connect_errors分析释疑 - 潇湘隐者 - 博客园

报错2:kafka消费不到数据

原因:我创建的主题的分区数不足,手动添加分区数 和canal的conf/example中的instance.properties里边设置的分区数相同即可.

 执行如下命令:

//1.查看主题详情 查看其分区数

kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --topic ODS_base_DB_C

//2.手动添加分区数

kafka-topics.sh --bootstrap-server hadoop102:9092 --alter --partitions 4 --topic ODS_base_DB_C