数据湖探索 DLI-Kafka Sink配置发送失败重试机制:解决方案

时间：2025-02-12 15:00:38

数据湖探索 DLI

解决方案

在SQL语句中配置发送失败重试：connector.properties.retries=5

create table kafka_sink(     car_type string    , car_name string    , primary key (union_id) not enforced) with (    "connector.type" = "upsert-kafka",    "connector.version" = "0.11",    "connector.properties.bootstrap.servers" = "xxxx:9092",    "connector.topic" = "kafka_car_topic ",    "connector.sink.ignore-retraction" = "true",    "connector.properties.retries" = "5",    "format.type" = "json");

上一篇：数据湖探索 DLI-从DLI导入数据到OBS，数据量不一致怎么办？:操作步骤

下一篇：数据湖探索 DLI-从DLI导入数据到OBS，数据量不一致怎么办？:操作步骤