操作场景
CKafka 连接器支持 Schema 管理功能,您可以将创建好的 Schema 绑定到具体的数据流入任务上,将会按该 Schema 对流入的数据进行格式校验。
操作步骤
创建 Schema
接下来以订阅 MySQL 数据到 ES 为例为您介绍新建链路的操作步骤。
2. 在左侧导航栏选择连接器 > Schema 管理,选择好地域后,单击新建 Schema,填写 Schema 信息。
Schema 名称:填写 Schema 名称,只能包含字母、数字、下划线、"-"、"."。
描述:可选,填写 Schema 描述信息。
字段配置:添加字段,最多支持添加100条字段。
字段名:填写字段名称。
类型:支持 BOOLEAN,INT8,INT16,INT32,INT64,FLOAT32,FLOAT64,STRING 八种类型。
允许为 NULL:校验上游是否存在该字段。允许为 NULL 代表:如果上游没有该字段,自动添加设置的默认值字段。
说明:
关于字段配置中是否为 NULL 的详细说明:
true:
上游字段存在且符合要求:写入。
上游字段存在且不符合要求:不写入。
上游字段不存在:写入默认值。
false:
上游字段存在且符合要求:写入。
上游字段存在且不符合要求:不写入。
上游字段不存在:不写入。
描述:填写字段描述。
3. 单击确定,完成 Schema 创建。
删除 Schema
在 Schema 管理列表页面,单击操作列的删除,在弹窗中二次确认后,即可删除。
绑定任务
Schema 创建完成后,可以绑定到具体的数据流入任务上。
1. 在 Schema 管理列表页面,单击目标 Schema 的“ID”,进入基本信息页面。
2. 在页面上方选择关联任务页签,单击绑定任务,勾选具体的数据流入任务,完成绑定。
解绑任务
1. 在 Schema 管理列表页面,单击目标 Schema 的“ID”,进入基本信息页面。
2. 在页面上方选择关联任务页签,单击绑定任务操作栏的解绑,完成解绑。
说明:
解绑后,将不会按该 Schema 对数据进行格式校验。
本页内容是否解决了您的问题?