flink如何读取pxc集群的binlog日志

Question

flink无法读取mysql的binlog日志
最近有个需求，需要使用flink实时同步mysql的数据到另一个mysql，后来发现源端的mysql是使用pxc的方式部署的集群模式。不知道是否和这个集群有关系，但现在的问题就是flink无法或许这个库的日志，如果更换其他的库可以正常实时增量查询
下面是代码，运行在flink sql client中，

SET execution.checkpointing.interval = 1s;

CREATE TABLE flink_cdc (
`name` string,
`sex` string,
`age` string,
PRIMARY KEY (`name`) NOT ENFORCED
) WITH (
--'connector' = 'mysql-cdc',
--'hostname' = '11111',
--'port' = '3306',
--'username' = 'root',
--'password' = '123456',
--'database-name' = 'museum',
--'table-name' = 'flink_cdc'
--);
'connector' = 'mysql-cdc',
'hostname' = '10.130.1.11',
'port' = '3306',
'username' = 'root',
'password' = '%tgb6YHN',
'database-name' = 'museum',
'table-name' = 'flink_source'
);


CREATE TABLE flink_test (
`name` string,
`sex` string,
`age` string,
PRIMARY KEY (`name`) NOT ENFORCED
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://xxxx:4506/museum',
'driver' = 'com.mysql.jdbc.Driver',
'username' = 'root',
'password' = '123456',
'table-name' = 'flink_test'
);

insert into flink_test select * from flink_cdc;

Answer 1

测试过 Flink 连接集群的端口吗？可以把日志附上