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

时间:2024-07-01 21:07:20

示例

将kafkaSink的数据输出到Kafka中
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
create table kafkaSink(
  car_id STRING,
  car_owner STRING,
  car_brand STRING,
  car_speed INT)
with (
  'connector.type' = 'kafka',
  'connector.version' = '0.10',
  'connector.topic' = 'test-topic',
  'connector.properties.bootstrap.servers' = 'xx.xx.xx.xx:9092',
  'connector.sink-partitioner' = 'round-robin',
  'format.type' = 'csv'
);
support.huaweicloud.com/sqlreference-dli/dli_08_0308.html