flinkcdc监控mysql整个库的binlog

Question

问题遇到的现象和发生背景

flinkcdc监控mysql整个库的binlog

遇到的现象和发生背景，请写出第一个错误信息

flinkcdc2.2.1使用datastream的方式监控mysql其中一个库的binlog,程序不报错,但是也读取不到数据

用代码块功能插入代码，请勿粘贴截图。 不用代码块回答率下降 50%

但是把代码改为库中的某张表的时候就可以获取到数据

运行结果及详细报错内容

无

我的解答思路和尝试过的方法，不写自己思路的，回答率下降 60%

无

我想要达到的结果，如果你需要快速回答，请尝试 “付费悬赏”

flinkcdc可以监控mysql的一整个库

Answer 1

在使用 Flink CDC (Change Data Capture) 监控 MySQL 数据库时，如果你使用的是数据流的方式（即使用 DataStream API），那么你可以使用以下代码来监控 MySQL 整个库的 binlog：

DataStream<Row> stream = FlinkCdcConnectors.getTableRows(
    env, // Flink StreamExecutionEnvironment
    "connector_name", // connector name
    "database_name", // database name
    "table_name", // table name
    "server_id", // server id
    "binlog_dir", // binlog directory
    "username", // username
    "password" // password
);