flink CDC监控mysql表，表更新报错Encountered change event for table test.student whose schema isn't known to this connector

[ververica]

flink CDC监控mysql表，表更新报错Encountered change event for table test.student whose schema isn't known to this connector

[zZxiaowang]

我的库名是小写，但是也会出现这种问题

我试了试 。CDC的earliest模式在这块是不支持下划线的

[shizhengchao]

properties.setProperty("database.history.kafka.bootstrap.servers", "kafka1:9092");
properties.setProperty("database.history.kafka.topic", "demo1");
properties.setProperty("key.converter", "org.apache.kafka.connect.json.JsonConverter");
properties.setProperty("value.converter", "org.apache.kafka.connect.json.JsonConverter");
上面这些属性可以不设置，但似乎没什么影响，我按照 你的代码，没有重现你的问题，我这边是正常的。你可以按照下面的方法定位下

1. 首先确保下mysql是否设置了如下配置：

server-id         = 123
log_bin           = mysql-bin 
binlog_format     = ROW 
binlog_row_image  = FULL 
expire_logs_days  = 10 

2. 如果mysql设置正确，再确认user是否用足够的权限

GRANT SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'user' IDENTIFIED BY 'password';

[yangxusun9]

properties.setProperty("database.history.kafka.bootstrap.servers", "kafka1:9092");
properties.setProperty("database.history.kafka.topic", "demo1");
properties.setProperty("key.converter", "org.apache.kafka.connect.json.JsonConverter");
properties.setProperty("value.converter", "org.apache.kafka.connect.json.JsonConverter");
上面这些属性可以不设置，但似乎没什么影响，我按照 你的代码，没有重现你的问题，我这边是正常的。你可以按照下面的方法定位下

1. 首先确保下mysql是否设置了如下配置：

server-id         = 123
log_bin           = mysql-bin 
binlog_format     = ROW 
binlog_row_image  = FULL 
expire_logs_days  = 10 

1. 如果mysql设置正确，再确认user是否用足够的权限

GRANT SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'user' IDENTIFIED BY 'password';

[yangxusun9]

是Mysql DatabaseName大小写的问题，我猜想应该是debezium 会将 我传入的 ‘Test’ 转化为 ‘test’，然后去找对应的schema，所以会抛这样的异常

[shizhengchao]

是Mysql DatabaseName大小写的问题，我猜想应该是debezium 会将 我传入的 ‘Test’ 转化为 ‘test’，然后去找对应的schema，所以会抛这样的异常

正解，是debezium获取到mysql里的所有数据库的时候，会和你传入的 dbname比较，比较的时候传入的dbname被转成小写了，所以tableid找不到。

[lykpass]

我的库名是小写，但是也会出现这种问题

[lcchaoliu]

mysql CDC的earliest模式不支持表名带下划线的. 这个问题官方什么时候回修复