租户端 大数据 大数据计算 操作指南 流计算作业开发 在线开发模式 添加数据源

添加数据源

最近更新时间: 2019-11-26 14:47:12

在IDE界面拖拽数据源插件“Kafka source”，双击拖拽的Kafka source弹出参数设置框（首次拖拽插件时，自动弹出），配置参数后，点击右上角的“X”进行保存。 配置参数说明如下：

  • 名称：即插件名称，可修改

  • 数据源：可选择有项目下有权限的数据源

  • topic名称：可选择已选数据源下的topic

  • 中间表名称：非必填，为将Kafka中的数据进行结构化后注册表的名称；

  • Operator并发度：非必填，如不指定将按照作业默认并行数执行；

  • Kafka消费位置：支持Latest（最近时间）、Earliest（最早时间）、Custom（自定义选择开始时间）三种方式，默认Latest time执行。