PG库的flink cdc是基于查询的吗?
以下为热心网友提供的参考意见
是的，Flink CDC（Change Data Capture，变更数据获取）是一个开源的是的，Flink CDC（Change Data Capture，变更数据获取）是一个开源的数据库变更日志捕获和处理框架，它能够实时地从各种数据库（如MySQL、PostgreSQL、Oracle、MongoDB等）中捕获数据变更并将其转换为流式数据。Flink-cdc是Flink社区开发的flink-cdc-connectors组件，这是一个可以直接从MySQL、PostgreSQL等数据库直接读取全量数据和增量变更数据的source组件。
Flink CDC支持基于查询和基于日志的两种模式。对于基于查询的模式，Flink CDC通过监测并捕获数据库的binlog来获取数据变更。对于基于日志的模式，Flink CDC通过解析数据库的redo log或undo log来获取数据变更。在这两种模式下，Flink CDC都是基于Flink SQL来进行数据同步的。