1. 概述
1.1 版本
| FineDataLink 版本 | 功能变动 |
|---|---|
| 5.0.6.1 | 实时任务支持读取 RocketMQ 数据源 |
1.2 功能简介
FineDataLink 支持连接 RocketMQ，实时任务可使用「RocketMQ输入」算子，读取该数据源。
2. 准备工作
2.1 前提条件
详情请参见：前提条件
2.2 版本和JAR文件
| 支持的数据源版本 | 需要的 JAR 文件 |
|---|---|
| RocketMQ 4.x |
下载压缩包后，解压，将里面的 JAR 文件：
若 FineDataLink 为独立部署的工程，将驱动文件放置到 %FDL_home%\webapps\webroot\WEB-INF\lib 下；放置后，需要重启 FDL 工程。
若 FineDataLink 为 OPS 部署的工程，将驱动文件上传至 FineDataLink 工程外挂目录的 customlib 文件夹下
如忘记工程外挂目录位置，请参考文档查询：导出项目部署信息；放置后，需要重启 FDL 工程。
2.3 具体连接步骤
创建数据连接步骤请参见：创建并管理数据源
| 设置项 | 说明 |
|---|---|
| RocketMQ服务地址 | namesrv地址（例如：127.0.0.1:9876） 对于RocketMQ集群，可以在文本框中输入多个地址，以英文逗号分隔 |
| 认证方式 | 支持两种认证方式：无认证、用户名密码 选择「用户名密码」时，需要填写用户名、密码 |
| 密码 | 支持详情请看下图：
|
上一篇：配置RabbitMQ数据源
