请教下大家,官网中对于时态表的定义的案例是基于debezium的,我现在具基于canal这样定义有问题吗?定义如下
create table produce(
id string,
name string,
price decimal(10,4)
update_time timestamp(3) metadata from ‘timestamp’ virtual,
primary key(id) not enforced,
watermark for update_time as update_time
)with(
‘connector’=‘Kafka’,
‘topic’=‘product’,
‘scan.startup.mode’=‘earliest-offset’,
‘properties.bootstrap.server’=‘localhost:9092’
‘value.format’=‘canal-Jason’
);


主要是 metadata那块 填写timestamp 对吗?

回复