1. 概述
1.1 版本
版本 | 功能变动 |
---|---|
4.1.11.4 | - |
1.2 应用场景
为了便于用户通过配置 Pulsar 消费者的方式,实时从 Pulsar 中取数。FineDataLink 支持配置 Pulsar 数据连接,进行实时任务的读取和写入。
2. 配置数据连接
2.1 前提条件
详情请参见:前提条件
2.2 收集连接信息
在连接之前,请收集以下信息:
webService地址;
broker地址;
若是用户名密码认证,需要收集用户名和密码;
2.3 添加驱动
pulsar 连接需要预先把 驱动 包放到%FDL_home%\webapps\webroot\WEB-INF\lib 下,重启工程。
2.4 具体连接步骤
创建数据连接步骤请参见:创建并管理数据源
部分设置项说明:
数据连接配置项如下图所示:
配置项 | 配置说明 |
---|---|
数据连接名称 | 填写数据连接名称 |
webService地址 | 配置Pulsar的地址 示例格式:http://demo.fanruan.com:8080 支持https格式 |
broker地址 | 配置broker地址 示例格式:pulsar+ssl://demo.fanruan.com:6650(有TLS加密) 或pulsar://demo.fanruan.com:6650(无TLS加密) |
认证方式 |
|
编码 | 默认编码是utf-8 |