讯享网<tr> <th bgcolor="#C0C0C0"><strong>数据源类型</strong></th> <th bgcolor="#C0C0C0"><strong>Reader（读）</strong></th> <th bgcolor="#C0C0C0"><strong>Writer（写）</strong></th> <th bgcolor="#C0C0C0"><strong>支持的版本及认证方式</strong></th> </tr> <tr> <td bgcolor="white">Kafka</td> <td bgcolor="white">支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">版本：2.0.1，认证方式：无认证<br/>版本：2.0.1，认证方式：Kerberos认证<br/>版本：2.3.1，认证方式：无认证（仅支持读）<br/>版本：2.3.1，认证方式：SASL_Plaintext（仅支持读）<br/>版本：2.7.1，认证方式：无认证（仅支持读）<br/>版本：2.7.1，认证方式：SASL_Plaintext（仅支持读）</td> </tr> <tr> <td bgcolor="white">MySQL</td> <td bgcolor="white">支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">版本：5.7、8.0</td> </tr> <tr> <td bgcolor="white">Oracle</td> <td bgcolor="white">支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">版本：11g、12g、19c</td> </tr> <tr> <td bgcolor="white">PostgreSQL</td> <td bgcolor="white">支持</td> <td bgcolor="white">不支持</td> <td bgcolor="white">版本：13.2</td> </tr> <tr> <td bgcolor="white">TeleDB</td> <td bgcolor="white">支持</td> <td bgcolor="white">不支持</td> <td bgcolor="white">版本：5.7</td> </tr> <tr> <td bgcolor="white">SQLServer</td> <td bgcolor="white">支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">版本：2012、2016、2017、2019</td> </tr> <tr> <td bgcolor="white">TelePG</td> <td bgcolor="white">支持</td> <td bgcolor="white">不支持</td> <td bgcolor="white">版本：42.2.9</td> </tr> <tr> <td bgcolor="white">Hive</td> <td bgcolor="white">不支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">平台内置Hive集群</td> </tr> <tr> <td bgcolor="white">Iceberg</td> <td bgcolor="white">不支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">平台内置Iceberg集群，版本：1.2.0</td> </tr> <tr> <td bgcolor="white">Kudu</td> <td bgcolor="white">不支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">版本：1.16.0</td> </tr> <tr> <td bgcolor="white">StarRocks</td> <td bgcolor="white">不支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">版本：1.19、2.4、3.2</td> </tr> <tr> <td bgcolor="white">Doris</td> <td bgcolor="white">不支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">版本：1.1、1.2、2.0</td> </tr> <tr> <td bgcolor="white">Paimon</td> <td bgcolor="white">不支持</td> <td bgcolor="white">支持</td> <td bgcolor="white">版本：0.8</td> </tr> 

<tr> <th bgcolor="#C0C0C0"><strong>配置项</strong></th> <th bgcolor="#C0C0C0"><strong>描述</strong></th> </tr> <tr> <td bgcolor="white">任务名称</td> <td bgcolor="white">最多128个字符，仅允许包含中文、字母、数字、“-”和“_”，仅能以中文和字母开头<br/>注意：同一项目-集群下不允许存在同名任务</td> </tr> <tr> <td bgcolor="white">负责人</td> <td bgcolor="white">可选择项目下任意成员，默认为创建任务的用户</td> </tr> <tr> <td bgcolor="white">任务类型</td> <td bgcolor="white">在实时传输任务中，如需将表结构不一致的多张来源表分别同步至不同的去向表（Topic），任务类型请选择多表（Topic）同步；如需将表结构一致的多张分库分表同步至同一去向表（Topic），任务类型请选择分库分表同步。</td> </tr> <tr> <td bgcolor="white">引擎版本</td> <td bgcolor="white">当前仅支持FLINK-1.14版本</td> </tr> <tr> <td bgcolor="white">引用参数组</td> <td bgcolor="white"> 

参数组的使用场景：
1）任务导入导出时对库名、Topic名等进行替换。
2）任务常用的高级配置-自定义参数配置为参数组，可实现不同任务间的自定义参数复用。
功能使用注意事项：
1）同一实时同步任务内多个参数组内有相同参数项时，系统取排在前面的参数组的参数值。
2）如果字段映射支持的内置变量与参数组参数冲突时，内置变量优先级更高。
3） 如果高级设置填写的参数与参数组参数冲突时，则高级设置填写的参数优先级更高。
4）如果导入引用参数组的实时同步任务时，会检测导入端是否存在同名参数组，如不存在则检测不通过，导入失败。如导入端存在同名参数组，则在导入端会将任务引用的参数组id替换为导入端同名参数组的id。
功能详细使用步骤：
数据传输-实时同步任务：“引用参数组”配置项选取需引用的参数组。
1）如参数组的使用场景是：任务常用的高级配置-自定义参数配置为参数组，可实现不同任务间的自定义参数复用，则“引用参数组”配置项选取需引用的参数组即可。
2）如参数组的使用场景是：任务导入导出时对库名、Topic名等进行替换，除“引用参数组”配置项选取需引用的参数组外，请在使用变量处按照${参数组名称}的格式填写参数组参数。示例详见下图。

支持使用参数组参数的位置包含：
1）数据来源：
- 数据源类型为Kafka-【topic名称】
- 任务类型为多表同步，数据源类型为MySQL、Oracle、TeleDB、SQLServer-【数据库名称】
- 任务类型为多表同步或分库分表同步，数据源类型为Oracle，增量读取方式为ogg-【Topic名称】
- 来源为Kafka、消费起始位点为时间戳
- 来源为MySQL、消费起始位点为时间戳
- 来源为MySQL、消费起始位点为指定binlog日志-binlog日志位置
- 来源为Oracle、增量读取方式为logminer、消费起始位点为时间戳
- 来源为Oracle、增量读取方式为logminer、消费起始位点为指定scn
- 来源为Oracle、增量读取方式为ogg、消费起始位点为时间戳
- 来源为SQLServer、消费起始位点为指定lsn
- 来源为TeleDB、消费起始位点为指定binlog日志-binlog日志位置
- 来源为TelePG、消费起始位点为指定lsn
2）数据去向：
- 数据源类型为Kudu-【去向表名】
- 数据源类型为Iceberg、Arctic、Hive-【去向库名】和【去向表名】
- 数据源类型为Kafka-【去向Topic】
3）字段映射：
数据去向为Kudu、Iceberg、Arctic、Hive时，来源表字段类型为自定义表达式时，支持填写参数组参数。

讯享网 </td> </tr> <tr> <td bgcolor="white">引擎版本</td> <td bgcolor="white">当前仅支持FLINK-1.14版本</td> </tr> <tr> <td bgcolor="white">插件版本</td> <td bgcolor="white">支持的插件版本含：1.x、2.x，新建任务仅支持2.x版本。</td> </tr> 

<tr> <th bgcolor="#C0C0C0"><strong>配置项</strong></th> <th bgcolor="#C0C0C0"><strong>描述</strong></th> </tr> <tr> <td bgcolor="white">数据源</td> <td bgcolor="white">仅可选择类型为Kafka的当前项目组下数据源</td> </tr> <tr> <td bgcolor="white">Topic</td> <td bgcolor="white">请输入Topic名称。如需读取多个Topic，请点击“+添加Topic”输入多个需读取的Topic名称</td> </tr> <tr> <td bgcolor="white">序列化方式</td> <td bgcolor="white">可选择json、canal-json、debezium-json、maxwell-json、ogg-json。<br/>1）如果选择json，解析Topic schema时仅解析首层字段。<br/>示例：<br/>{&#34;table&#34;:&#34;OGG_TEST.ORDERS&#34;,&#34;op_type&#34;:&#34;I&#34;,&#34;op_ts&#34;:&#34;2020-05-29 10:01:27.000067&#34;,&#34;current_ts&#34;:&#34;2020-05-29T18:01:33.062000&#34;,&#34;pos&#34;:&#34;000000048&#34;,&#34;after&#34;:{&#34;OID&#34;:&#34;1&#34;,&#34;PID&#34;:&#34;2&#34;,&#34;NUM&#34;:&#34;3&#34;}}<br/>则字段映射中来源Topic字段为：table、op_type、op_ts、current_ts、pos、after。<br/>2）如果选择canal json，解析Topic schema时除data字段外仅解析首层字段，data嵌套字段内则子字段作为来源Topic字段。<br/>示例：<br/><span style="font-weight: bold;">insert</span><br/>{&#34;data&#34;:[{&#34;id&#34;:22,&#34;name&#34;:&#34;opt&#34;,&#34;age&#34;:123,&#34;address&#34;:&#34;北京市&#34;}],&#34;type&#34;:&#34;INSERT&#34;}<br/><span style="font-weight: bold;">update</span><br/>{&#34;data&#34;:[{&#34;id&#34;:22,&#34;name&#34;:&#34;opt&#34;,&#34;age&#34;:123,&#34;address&#34;:&#34;北京市&#34;}],&#34;type&#34;:&#34;DELETE&#34;}<br/>{&#34;data&#34;:[{&#34;id&#34;:22,&#34;name&#34;:&#34;opt11&#34;,&#34;age&#34;:123,&#34;address&#34;:&#34;北京市&#34;}],&#34;type&#34;:&#34;INSERT&#34;}<br/><span style="font-weight: bold;">delete</span><br/>{&#34;data&#34;:[{&#34;id&#34;:22,&#34;name&#34;:&#34;opt11&#34;,&#34;age&#34;:123,&#34;address&#34;:&#34;北京市&#34;}],&#34;type&#34;:&#34;DELETE&#34;}<br/>则字段映射中来源Topic字段为：id、name、age、address、type。<br/>3）如果选择debezium-json，解析Topic schema时除before/after字段外仅解析首层字段，以before/after嵌套字段内的子字段作为来源Topic字段。<br/>示例：<br/><span style="font-weight: bold;">insert</span><br/>{&#34;before&#34;:null,&#34;after&#34;:{&#34;id&#34;:22,&#34;name&#34;:&#34;opt1&#34;,&#34;age&#34;:null},&#34;op&#34;:&#34;c&#34;}<br/><span style="font-weight: bold;">update</span><br/>{&#34;before&#34;:{&#34;id&#34;:22,&#34;name&#34;:&#34;opt1&#34;,&#34;age&#34;:null},&#34;after&#34;:null,&#34;op&#34;:&#34;d&#34;}<br/>{&#34;before&#34;:null,&#34;after&#34;:{&#34;id&#34;:22,&#34;name&#34;:&#34;opt1123&#34;,&#34;age&#34;:null},&#34;op&#34;:&#34;c&#34;}<br/><span style="font-weight: bold;">delete</span><br/>{&#34;before&#34;:{&#34;id&#34;:22,&#34;name&#34;:&#34;opt1123&#34;,&#34;age&#34;:null},&#34;after&#34;:null,&#34;op&#34;:&#34;d&#34;}<br/>则字段映射中来源Topic字段解析为：id、name、age、op。 </td> </tr> <tr> <td bgcolor="white">格式转换</td> <td bgcolor="white">序列化格式为json时，支持格式转换。<br/>如勾选首层嵌套JSON平铺，会将首层中类型为row或map的嵌套字段解析为row类型并分解为单层结构，字段名称为“首层字段名称.次层字段名称”。<br/>示例Topic：<br/>{ &#34;obj&#34;: { &#34;time1&#34;: &#34;12:12:43Z&#34;, &#34;str&#34;: &#34;sfasfafs&#34;, &#34;lg&#34;: { &#34;name&#34;: &#34;1&#34; }, &#34;num&#34;: 3 }, &#34;arr&#34;: [ { &#34;f1&#34;: &#34;f1str11&#34;, &#34;f2&#34;: 134 }, { &#34;f1&#34;: &#34;f1str22&#34;, &#34;f2&#34;: 555 } ], &#34;map&#34;: { &#34;key1&#34;: 234, &#34;key2&#34;: 456 } }<br/>则字段映射中来源Topic字段解析为：obj.time1、obj.str、obj.lg、num、arr、map.key1、map.key2。 </td> </tr> <tr> <td bgcolor="white">消费起始位点</td> <td bgcolor="white">支持从最新数据、最早数据、指定时间戳开始读取。<br/>如从指定时间戳开始读取，请按“yyyy-MM-dd HH:mm:ss.SSS”格式填写，其中“.SSS”可不填。 </td> </tr> <tr> <td bgcolor="white">注意事项</td> <td bgcolor="white">如勾选首层嵌套JSON平铺，除解析出的“首层字段名称.次层字段名称”的列名外，首层和次层的字段名称不允许再包含“.”。如果首层或次层名称包含“.”，例如，首层字段名称：a.bc，此处字段名称：d.ef，则字段映射时请使用自定义表达式：`a.bc`.`d.ef` as 列名 表示该字段。 </td> </tr> 

讯享网<tr> <th bgcolor="#C0C0C0"><strong>配置项</strong></th> <th bgcolor="#C0C0C0"><strong>描述</strong></th> </tr> <tr> <td bgcolor="white">数据源</td> <td bgcolor="white">仅可选择当前项目组下该数据源类型的数据源</td> </tr> <tr> <td bgcolor="white">数据库</td> <td bgcolor="white">请选择数据库，支持模糊搜索库名</td> </tr> <tr> <td bgcolor="white">表</td> <td bgcolor="white">请勾选需要读取的表并点击“&gt;”加入右侧的已选表，可选取多张表。<br/><img src="https://study.sf.163.com/documents/uploads/projects/easytransfer-V3.21.0//1769c26da6d56405.png" alt="任务创建 - 图6" data-original="/documents/uploads/projects/easytransfer-V3.21.0//1769c26da6d56405.png" class="lazy"/><br/>注意：如某张来源表已被项目-集群内的其余实时同步任务采集，则表名后会展示“已采集”的标签，鼠标停留在标签时会提示已采集该表的任务名称。如仅需展示未采集表，可在穿梭框下方勾选“仅展示未采集表”。<br/><img src="https://study.sf.163.com/documents/uploads/projects/easytransfer-V3.21.0//1769c270a4cd425f.png" alt="任务创建 - 图7" data-original="/documents/uploads/projects/easytransfer-V3.21.0//1769c270a4cd425f.png" class="lazy"/><br/><img src="https://study.sf.163.com/documents/uploads/projects/easytransfer-V3.21.0//1769c271de42fb3b.png" alt="任务创建 - 图8" data-original="/documents/uploads/projects/easytransfer-V3.21.0//1769c271de42fb3b.png" class="lazy"/><br/></td> </tr> <tr> <td bgcolor="white">数据库时区</td> <td bgcolor="white">请选择数据库的时区，支持模糊搜索。 

默认值为Asia/Shanghai。

</tr> <tr> <td bgcolor="white">订阅类型</td> <td bgcolor="white">订阅类型包含：插入（Insert）、更新（Upsert）、删除(Delete），意指binlog的数据库变更类型，可多选，建议全选。</td> </tr> <tr> <td bgcolor="white">增量读取方式</td> <td bgcolor="white">由该数据库类型决定</td> </tr> <tr> <td bgcolor="white">消费起始位点</td> <td bgcolor="white">支持从最新数据、全量初始化、指定binlog日志开始读取。如选取全量初始化，则会先同步来源表的历史全量数据再实时同步增量更新数据，块大小和批量条数可根据需求自行调优。全量初始化默认开启并发读取，如果来源表存在主键则以主键作为切分键并发读取，如果来源表不存在主键则默认并发度为1。</td> </tr> </tbody></div> 

2）分库分表同步

讯享网<tr> <th bgcolor="#C0C0C0"><strong>配置项</strong></th> <th bgcolor="#C0C0C0"><strong>描述</strong></th> </tr> <tr> <td bgcolor="white">数据源</td> <td bgcolor="white">仅可选择当前项目组下该数据源类型的数据源。 

</tr> <tr> <td bgcolor="white">逻辑表</td> <td bgcolor="white">对于分库分表，表结构一致的分库分表对应于1个逻辑表。 请在此处依次逻辑表名称、分库分表的库名正则表达式和表名正则表达式。 

讯享网</tr> <tr> <td bgcolor="white">数据库时区</td> <td bgcolor="white">请选择数据库的时区，支持模糊搜索。 

</tr> <tr> <td bgcolor="white">订阅类型</td> <td bgcolor="white">订阅类型包含：插入（Insert）、更新（Upsert）、删除(Delete），意指binlog的数据库变更类型，可多选，建议全选。</td> </tr> <tr> <td bgcolor="white">增量读取方式</td> <td bgcolor="white">由该数据库类型决定</td> </tr> <tr> <td bgcolor="white">消费起始位点</td> <td bgcolor="white">支持从最新数据、全量初始化、指定binlog日志开始读取。如选取全量初始化，则会先同步来源表的历史全量数据再实时同步增量更新数据，块大小和批量条数可根据需求自行调优。全量初始化默认开启并发读取，如果来源表存在主键则以主键作为切分键并发读取，如果来源表不存在主键则默认并发度为1。</td> </tr> </tbody></div> 

讯享网<tr> <th bgcolor="#C0C0C0"><strong>配置项</strong></th> <th bgcolor="#C0C0C0"><strong>描述</strong></th> </tr> <tr> <td bgcolor="white">数据源 </td> <td bgcolor="white"> 

</tr> <tr> <td bgcolor="white">设置来源表与去向表映射</td> <td bgcolor="white"> 请选择各来源表对应的去向Iceberg库表。如任务类型为分库分表同步时，此处选择各来源逻辑表对应的去向Iceberg库表。<br/> 

讯享网 </td> </tr> <tr> <td bgcolor="white">写入分区</td> <td bgcolor="white">如写入表为分区表，需配置写入分区。支持根据数据写入时间分区、根据字段内容动态分区和根据数据生成时间分区。<br/>1）分区方式为根据数据生成时间分区或根据数据写入时间分区时，支持填写内置变量：yyyy、MM、dd、HH、mm、ss，分别表示数据生成时间/数据写入时间的年、月、日、时、分、秒，支持多个内置变量组合使用，如：yyyy-MM-dd，表示数据生成时间/数据写入时间的当日，示例：2022-01-02。<br/>2）分区方式为根据字段内容动态分区时，支持选择来源表字段，会将源端对应字段所在数据行写入到表对应的分区中。示例：选择来源表字段为A，当A字段值为aa时，实时同步会将数据写入到对应的aa分区中，当A字段值为bb时，实时同步会将数据写入到对应的bb分区中。<br/>3）请保证所有去向表的分区结构保持一致，否则任务可能运行失败。 

</tr> <tr> <td bgcolor="white">写入规则</td> <td bgcolor="white">支持的写入规则为：insert into（追加）、upsert（主键和分区键均冲突，覆盖原记录）。<br/>注意：使用upsert要求Iceberg表同时满足两个条件：1、版本是V2，2、有主键或分区键，否则任务会报错。 </td> </tr> 

讯享网<tr> <th bgcolor="#C0C0C0"><strong>配置项</strong></th> <th bgcolor="#C0C0C0"><strong>描述</strong></th> </tr> <tr> <td bgcolor="white">数据源 </td> <td bgcolor="white"> 

</tr> <tr> <td bgcolor="white">设置来源表（Topic）与去向Topic映射</td> <td bgcolor="white"> 请选择各来源表（Topic）对应的去向Topic。<br/><img src="https://study.sf.163.com/documents/uploads/projects/easytransfer-V3.21.0//dcf.png" alt="任务创建 - 图13" data-original="/documents/uploads/projects/easytransfer-V3.21.0//dcf.png" class="lazy"/><br/>批量设置源表（Topic）和去向Topic映射： 

讯享网 </td> </tr> <tr> <td bgcolor="white">同步主键</td> <td bgcolor="white">来源为除Kafka外数据源类型时，需要设置同步主键。<br/>1）同步时会使用同步主键值作为Kafka记录的key，确保同主键的变更有序写入Kafka的同一分区。<br/>2）如来源表有主键，建议使用来源表字段作为同步主键；如来源表无主键，建议使用其他非主键的一个或几个字段的联合，代替主键作为Kafka记录的key，选取多个字段联合作为同步主键，字段拼接时字段间以;分隔。<br/>3）如同步主键为空，则同步时Kafka记录的key为空。如果要确保表的变更有序写入Kafka，则选择写入的Kafka Topic必须是单分区。</td> </tr> <tr> <td bgcolor="white">序列化方式</td> <td bgcolor="white"> 

</tr> <tr> <td bgcolor="white">update变更对应一条记录</td> <td bgcolor="white"> 

讯享网</tr> 

<tr> <th bgcolor="#C0C0C0"><strong>配置项</strong></th> <th bgcolor="#C0C0C0"><strong>描述</strong></th> </tr> <tr> <td bgcolor="white">字段映射全局映射</td> <td bgcolor="white">点击“同名映射”或“同行映射”，则所有Topic-表映射的字段映射均按照此规则去配置字段映射。<br/>同名映射：根据去向表字段名称匹配同名的来源Topic字段名称，若无法匹配则来源Topic字段置为自定义表达式。<br/>同行映射：根据去向表字段序号匹配序号相同的来源Topic字段名称，若无法匹配则来源Topic字段置为自定义表达式。</td> </tr> <tr> <td bgcolor="white">来源Topic-去向表</td> <td bgcolor="white">支持根据来源Topic、去向库名、去向表名搜索符合搜索条件的Topic-表映射。<br/>在页面左侧切换Topic-表映射时，可针对选中的Topic-表映射配置字段映射。</td> </tr> 

讯享网<tr> <th bgcolor="#C0C0C0"><strong>配置项</strong></th> <th bgcolor="#C0C0C0"><strong>描述</strong></th> </tr> <tr> <td bgcolor="white">获取最新表结构</td> <td bgcolor="white"> 

</tr> <tr> <td bgcolor="white">一键解析Topic字段</td> <td bgcolor="white">进入字段映射模块时默认会解析各Topic的字段名称和字段类型，点击“一键映射Topic字段”会重新解析一次最新的Topic字段名称和字段类型，在Topic schema更新、首次解析不符合预期等情况下可点击此按钮。</td> </tr> <tr> <td bgcolor="white">同名映射</td> <td bgcolor="white">根据去向表字段名称匹配同名的来源Topic字段名称，若无法匹配则来源Topic字段置为自定义表达式。</td> </tr> <tr> <td bgcolor="white">同行映射</td> <td bgcolor="white">根据去向表字段序号匹配序号相同的来源Topic字段名称，若无法匹配则来源Topic字段置为自定义表达式。</td> </tr> <tr> <td bgcolor="white">设置自定义表达式字段类型</td> <td bgcolor="white">如果存在自定义表达式引用来源Topic字段且字段映射未指定类型时，请点击“设置自定义表达式字段类型”按钮设置引用字段的类型，否则任务会运行失败。</td> </tr> <tr> <td bgcolor="white">来源Topic字段</td> <td bgcolor="white">支持选择Topic字段或自定义表达式。选中Topic字段时，支持输入或选择Topic字段名称，如果来源Topic为空，此处支持手动填写字段名称；如果来源Topic非空，此处默认会自动解析Topic首层字段名称。选中自定义表达式时，请按照格式填写：“表达式” as 列名，支持填写常量、Flink函数、内置变量current_timestamp（表示数据写入时间），示例：current_timestamp as 列名。</td> </tr> <tr> <td bgcolor="white">字段类型</td> <td bgcolor="white">系统支持推断Topic字段的字段类型。选中某个Topic字段时，会展示该字段的推断类型，如与字段实际类型存在差异，可手动调整切换字段类型。</td> </tr> 

讯享网<tr> <th bgcolor="#C0C0C0"><strong>来源Topic字段类型</strong> </th> <th bgcolor="#C0C0C0"><strong>Hive字段类型</strong></th> </tr> <tr> <td bgcolor="white">int</td> <td bgcolor="white">int</td> </tr> <tr> <td bgcolor="white">tinyint</td> <td bgcolor="white">tinyint</td> </tr> <tr> <td bgcolor="white">smallint</td> <td bgcolor="white">smallint</td> </tr> <tr> <td bgcolor="white">bigint</td> <td bgcolor="white">bigint</td> </tr> <tr> <td bgcolor="white">float</td> <td bgcolor="white">float</td> </tr> <tr> <td bgcolor="white">double</td> <td bgcolor="white">double</td> </tr> <tr> <td bgcolor="white">decimal(38,18) </td> <td bgcolor="white">decimal(p,s)</td> </tr> <tr> <td bgcolor="white">timestamp</td> <td bgcolor="white">timestamp</td> </tr> <tr> <td bgcolor="white">date</td> <td bgcolor="white">date</td> </tr> <tr> <td bgcolor="white">不映射字段类型</td> <td bgcolor="white">char(n)</td> </tr> <tr> <td bgcolor="white">string</td> <td bgcolor="white">varchar(n) </td> </tr> <tr> <td bgcolor="white">string</td> <td bgcolor="white">string</td> </tr> <tr> <td bgcolor="white">boolean</td> <td bgcolor="white">boolean</td> </tr> <tr> <td bgcolor="white">varbinary</td> <td bgcolor="white">binary</td> </tr> <tr> <td bgcolor="white">map</td> <td bgcolor="white">map</td> </tr> <tr> <td bgcolor="white">array</td> <td bgcolor="white">array</td> </tr> <tr> <td bgcolor="white">不映射字段类型</td> <td bgcolor="white">struct</td> </tr> <tr> <td bgcolor="white">不映射字段类型</td> <td bgcolor="white">union</td> </tr> 

<tr> <th bgcolor="#C0C0C0"> <strong>参数类型</strong></th> <th bgcolor="#C0C0C0"><strong>数据源类型</strong></th> <th bgcolor="#C0C0C0"><strong>参数名称</strong></th> <th bgcolor="#C0C0C0"><strong>参数说明</strong></th> </tr> <tr> <td bgcolor="white">数据来源</td> <td bgcolor="white">Kafka</td> <td bgcolor="white">source.json.timestamp-format.standard</td> <td bgcolor="white">任务支持的timestamp格式。同一任务仅支持一类timestamp格式，默认值为SQL，可填写值为：SQL、ISO_8601、RFC3339。 </td></tr> <tr><td bgcolor="white">数据来源</td> <td bgcolor="white">MySQL</td> <td bgcolor="white">source.fields.convert-tinyint-one-boolean.enabled</td> <td bgcolor="white">用于控制MySQL表字段类型为tinyint时写入去向的字段类型。默认值为true，即按照boolean类型写入数据去向；值为false时，会按照tinyint类型写入数据去向。 </td></tr>