数据湖探索 DLI-Kafka源表:语法格式

时间:2025-02-12 15:00:46

语法格式

 1 2 3 4 5 6 7 8 91011121314
create table kafkaSource(  attr_name attr_type   (',' attr_name attr_type)*   (','PRIMARY KEY (attr_name, ...) NOT ENFORCED)  (',' WATERMARK FOR rowtime_column_name AS watermark-strategy_expression))with (  'connector' = 'kafka',  'topic' = '',  'properties.bootstrap.servers' = '',  'properties.group.id' = '',  'scan.startup.mode' = '',  'format' = '');
support.huaweicloud.com/sqlref-flink-dli/dli_08_0386.html