flink sql cdc如何获取元数据

[casel.chen]

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