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_'
> )

回复