首批通过分布式安全可靠测评,为关键业务系统打造
Sink Plugin 概述
更新时间:2026-04-14 15:40:47
Sink Plugin 的配置路径为 conf/sink.json,每个配置类都存在一个 config key。
【启动】boosterClass
功能:指定 Sink Plugin 的 Booster
默认值:无,必填
值的选择范围:下述 Plugins 或者额外实现的 plugin.jar 的 Booster
支持的版本:OMS 社区版 V4.0.0-CE 及之后版本
【错误处理】retryErrorCode
功能:重试的错误码
默认值:空
值的选择范围:JSON 数组
支持的版本:OMS 社区版 V3.3.1-CE 及之后版本
【错误处理】retryErrorMessage
功能:重试的错误消息
默认值:空
值的选择范围:JSON 数组
支持的版本:OMS 社区版 V3.3.1-CE 及之后版本
【错误处理】skipErrorCode
功能:跳过的错误码
默认值:空
值的选择范围:JSON 数组
支持的版本:OMS 社区版 V3.3.1-CE 及之后版本
【错误处理】skipErrorMessage
功能:跳过的错误消息
默认值:空
值的选择范围:JSON 数组
支持的版本:OMS 社区版 V3.3.1-CE 及之后版本
相关文档
| 分类 | 文档链接 |
|---|---|
| JDBC-Sink | JDBC-Sink |
| KafkaSink | KafkaSink |
| DataHubSink | DataHubSink |
| RocketMQSink | RocketMQSink |