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