wuchunfu/flink-cdc-catalog

Flink CDC Catalog

目前已经支持 MySQL、Postgres、Oracle、SQLServer CDC Catalog

Example

-- 注册 Catalog
CREATE CATALOG mysql_cdc_catalog WITH(
    'type' = 'flink_cdc',
    'base-url' = 'jdbc:mysql://10.0.8.2:3306',
    'default-database' = 'example',
    'username' = 'root',
    'password' = 'mysql2022#'
);

SELECT * FROM mysql_cdc_catalog.example.user_city /*+ OPTIONS('scan.startup.mode'='latest-offset') */

测试环境

# oracle
docker run -e "ACCEPT_EULA=Y" -e "MSSQL_SA_PASSWORD=Sqlserver@2022" -e "MSSQL_PID=Standard" -e "MSSQL_AGENT_ENABLED=true" -p 1433:1433 -d mcr.microsoft.com/mssql/server:2019-latest 

参考

1. 基于 Flink CDC 实现 Oracle 数据实时更新到 Kudu
2. Viewing Tables Accessible by Current User