创建FlinkServer数据连接
通过数据连接,访问不同的数据服务,当前FlinkServer支持HDFS、Kafka、Redis类型的数据连接。
创建FlinkServer数据连接步骤
- 访问Flink WebUI,请参考访问FlinkServer WebUI界面。
- 选择“系统管理 > 数据连接管理”,进入数据连接管理页面。
- 单击“创建数据连接”,在弹出的页面中选择数据连接类型,参考表1填写信息,单击“确定”,完成数据连接创建。创建完成后,可在对应数据连接的“操作”列对数据连接进行编辑、测试、删除等操作。
表1 创建数据连接信息 参数名称
参数描述
示例
数据连接类型
选择数据连接的类型,包含HDFS、Kafka、Redis。
选择Redis数据连接类型时,需提前准备“分布式缓存服务 Redis版”实例,并确保其“实例类型”为“Cluster集群”、“访问方式”为“免密访问”、同时“区域”和“虚拟私有云”需与Flink所在集群相同。
-
数据连接名称
数据连接的名称。
-
集群连接
配置管理里的集群连接名称。
HDFS类型数据连接需配置该参数。
-
Kafka broker
Kafka Broker实例的连接信息,格式为“IP地址:端口”,多个实例之间通过逗号分隔。
Kafka类型数据连接需配置该参数。
192.168.0.1:21005,192.168.0.2:21005
Redis部署方式
Redis部署方式,当前仅支持“Cluster”。
Redis类型数据连接需配置该参数。
Cluster
Redis服务器列表
Redis实例的连接信息,格式为“IP地址:端口”,多个实例之间通过逗号分隔。
Redis类型数据连接需配置该参数。
192.168.0.1:6379,192.168.0.2:6379
认证类型
- SIMPLE:表示对接的服务是非安全模式,无需认证。该方法创建的Kafka数据连接仅支持SIMPLE认证类型。
- KERBEROS:表示对接的服务是安全模式,安全模式的服务统一使用Kerberos认证协议进行安全认证。
-