3.2.3.实时数据同步

3.2.3.1.创建kafka数据源连接

在公共设置-数据源管理右键新建即可

partNum、repeetNum为整形

Bootstrap-servers：kafka地址

用户可自定义参数配置

3.2.3.2.实时数据同步配置

源头数据源默认选择kafka数据源

字段分隔符不能与hive导出表分隔符一致

字段配置：根据json文件的配置，例如使用RWH，则字段配置为：before,RWH

目标数据源为hive

导入前准备语句可自定义编辑

更新频次为秒表示每间隔多少秒，从kafka中读取一次数据

导出的hive表支持分区表，普通表直接插入，分区表只能包含一个日期型分区字段

配置完成后，点击执行，查看执行日志。

如在执行过程中，点击取消执行，日志显示任务已经停止。