连接器管理可分为两种类型:
内置连接器:由流计算 Oceanus 官方提供和维护。
自定义连接器:用户在依赖管理中上传 JAR 后,然后在自定义连接器页面引用并创建。
创建自定义连接器
1. 登录 流计算 Oceanus 控制台,选择连接器管理 > 自定义连接器 > 创建自定义连接器。在创建自定义连接器页面,选择依赖 JAR 包和版本,等待 Oceanus 解析完成,然后选择对应的 Connector,单击确定完成创建自定义连接器。完成创建后自定义连接器列表将出现刚创建的自定义连接器。
自定义连接器如果和 Oceanus 内置连接器相同或者同名,则 Oceanus 内置连接器将被自定义连接器替换。后续在 SQL 作业使用发布运行中将会优先自动匹配自定义连接器,内置连接器不会被匹配,请根据自身需求替换内置连接器。
创建自定义连接器如果无法解析出对应的 Connector,请自查自定义连接器 JAR 是否符合社区规范,请参考 flink 社区 Connector 规范重新打包上传解析使用。


编辑自定义连接器
登录 流计算 Oceanus 控制台,选择连接器管理 > 自定义连接器 > 选择自定义连接器编辑。选择依赖 JAR 包和版本,等待 Oceanus 解析完成,然后选择对应的 Connector,单击确定完成编辑自定义连接器。完成编辑后自定义连接器列表将出现刚编辑的自定义连接器。

删除自定义连接器
1. 在自定义连接器列表中可删除自定义连接器。
2. 当某个自定义连接器被某个作业使用或自动匹配后,无论此作业版本的状态是草稿还是停止、暂停或运行中都无法删除该自定义连接器。需将该作业版本删除后,才可删除该自定义连接器。