Hello, Flink sql cdc 还不支持获取元数据, 获取元数据的业务场景通常是怎么样的呢?
祝好, Leonard > 在 2021年6月23日,08:21,casel.chen <casel_c...@126.com> 写道: > > flink sql cdc如何获取元数据?像数据库名,表名,操作类型,binlog产生时间等。 > > > create table xxx_tbl ( > k_op varchar, -- 操作类型 > k_database varchar, -- 数据库名 > k_table varchar, -- 表名 > k_ts. BIGINT, -- binlog产生时间 > id BIGINT, > name. varchar > ) with ( > 'connector' = 'mysql-cdc', > ..... > 'meta.fields-prefix' = 'k_' > )