数据湖探索 DLI-Upsert Kafka结果表:参数说明

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

数据湖探索 DLI

表1 参数说明
参数	是否必选	说明
connector.type	是	connector类型，对于upsert kafka，需配置为'upsert-kafka'
connector.version	否	Kafka版本，仅支持：'0.11'
format.type	是	数据序列化格式，支持：'csv', 'json'及'avro'等
connector.topic	是	kafka topic名
connector.properties.bootstrap.servers	是	kafka brokers地址，以逗号分隔
connector.sink-partitioner	否	记录分区方式，支持：'fixed', 'round-robin'及'custom'
connector.sink-partitioner-class	否	'sink-partitioner'为'custom'时，需配置，如'org.mycompany.MyPartitioner'
connector.sink.ignore-retraction	否	是否忽略回撤消息，默认为false。回撤消息将以null值写入kafka
update-mode	否	支持：'append', 'retract'及'upsert'三种写入模式
connector.properties.*	否	配置kafka任意原生属性