Flink Sql使用mysql-cdc捕获多个表失败的问题

问题描述：

要捕获同一个库里的多个表的binlog，程序不报错，但是修改某个表后没有结果没有任何改变。

fllinkSql的with语句

WITH ( 'connector' = 'mysql-cdc',
 'hostname' = '%s',
 'port' = '%s',
 'username' = '%s',
 'password' = '%s',
 'database-name' = 'student',
 'debezium.skipped.operations'='d',
 'debezium.min.row.count.to.stream.results'='1000',
 'table-name' = 'tb1,tb2,tb3')

原因：

编译成debezium的配置后只在第一个表的前面加了数据库前缀。

解决方法：

WITH ( 'connector' = 'mysql-cdc',
 'hostname' = '%s',
 'port' = '%s',
 'username' = '%s',
 'password' = '%s',
 'database-name' = 'student',
 'debezium.skipped.operations'='d',
 'debezium.min.row.count.to.stream.results'='1000',
 'table-name' = 'student.tb1,student.tb2,student.tb3')//就是这个要全部加数据库前缀