1. 概述
1.1 版本
| FineDataLink 版本 | 功能变动 |
|---|---|
| 5.0.6.1 | 实时任务中新增「RocketMQ输入」算子，读取该数据源 |
1.2 功能简介
数据开发-实时任务中，新增「RocketMQ输入」算子，支持读取 RocketMQ 数据。如下图所示：
2. 操作步骤
2.1 读取 RocketMQ 数据
1）登录 FDL 工程，点击「数据开发>实时任务>新建」，新建实时任务，给实时任务自定义名称。如下图所示：
2）进入实时任务编辑界面后，拖入「RocketMQ输入」算子，设置数据连接、Topic、Tag、输出字段、同步类型。如下图所示：
各设置项说明如下表所示：
| 设置项 | 说明 |
|---|---|
| 数据连接 | 1）需要配置 RocketMQ 数据连接，详情请参见：配置RocketMQ数据源 2）可点击「数据源权限检测」按钮，检测数据连接是否正常 |
| Topic | 配置消息主题，选择消费哪个 Topic 的消息 |
| Tag | 消息标签，用来进一步区分某个 Topic 下的消息分类，消息从生产者发出即带上的属性，手动填入，只支持单个Tag 非必填 |
| 输出字段 | 配置读取消息中哪些信息传输给下游算子 |
| 同步类型 | 支持选择：存量+增量同步、仅增量同步 选择仅增量同步时，支持设置增量同步起点：
|
| 样本设置 | 从 topic 最早的消息开始采样，采样数据不超过「数据行数」 采样的数据，不影响任务实际运行时的同步的数据
|
3）点击「数据预览」，可查看读取的数据。如下图所示：
2.2 后续步骤
1）根据实际情况继续拖入其他算子处理数据或者将数据输出。
2）启动实时任务即可。
上一篇：RabbitMQ输入
