数据湖探索 DLI-Upsert Kafka结果表:示例

时间：2024-12-27 10:34:29

数据湖探索 DLI

示例

create table upsertKafkaSink(
  car_id STRING,
  car_owner STRING,
  car_brand STRING,
  car_speed INT,
  primary key (car_id) not enforced
)
with (
  'connector.type' = 'upsert-kafka',
  'connector.version' = '0.11',
  'connector.topic' = 'test-topic',
  'connector.properties.bootstrap.servers' = 'xx.xx.xx.xx:9092',
  'format.type' = 'csv'
);

上一篇：数据湖探索 DLI-Upsert Kafka结果表:语法格式

下一篇：数据湖探索 DLI-Upsert Kafka结果表:语法格式