报错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
