Hi，
引用 Jark 对邮件列表中另一个相关的问题的回答，详情可查看[1]。
希望对你有帮助。
[1] http://apache-flink.147419.n8.nabble.com/flink-sql-td8884.html#a
Best,
Hailong
在 2020-12-01 10:09:21，"王羽凡" 写道：
>flink-sql-client执行建表：
>
>CREATE TABLE source_xxx (
> id INT,
> ctime TIMESTAMP
>) WITH (
> 'connector' = 'kafka',
>
flink-sql-client执行建表：
CREATE TABLE source_xxx (
id INT,
ctime TIMESTAMP
) WITH (
'connector' = 'kafka',
'topic' = 'xxx',
'properties.bootstrap.servers' = 'localhost:9092',
'format' = 'debezium-json',
'scan.startup.mode' = 'earliest-offset',
'debezium-json.schema-include' = 'false',
