更新时间:2024-10-24 GMT+08:00

DMS Kafka连接参数说明

连接DMS的Kafka队列时,相关参数如表1所示。

作业运行中禁止修改密码或者更换用户。在作业运行过程中修改密码或者更换用户,密码不会立即生效且作业会运行失败。

表1 DMS Kafka连接参数

参数名

说明

取值样例

名称

连接的名称,根据连接的数据源类型,用户可自定义便于记忆、区分的连接名。

dms_link

服务类型

选择DMS Kafka版本,目前只有专享版。

专享版

Kafka Broker

Kafka专享版实例的地址,格式为 host:port。

-

Kafka SASL_SSL

选择是否打开客户端连接Kafka专享版实例时SSL认证的开关。当DMS Kafka实例的连接信息中启用的安全协议为“SASL_SSL”时需要开启。

开启Kafka SASL_SSL,则数据加密传输,安全性更高,但性能会下降。

说明:
启用SSL认证后,Kafka会将Kafka Broker连接地址视做域名不断进行解析,导致性能消耗。建议修改CDM集群对应的ECS主机(通过集群IP查找对应的ECS主机)中的“/etc/hosts”文件,为其添加Broker连接地址的自映射,以便客户端能够快速解析实例的Broker。例如Kafka Broker地址配置为10.154.48.120时,hosts文件中的自映射配置为:
10.154.48.120 10.154.48.120

用户名

开启Kafka SASL_SSL时显示该参数,表示连接DMS Kafka的用户名。

-

密码

开启Kafka SASL_SSL时显示该参数,表示连接DMS Kafka的密码。

-

属性配置

  • 当DMS Kafka实例的连接信息中启用的安全协议后,需要添加数据加密方式属性:属性名称填写为security.protocol,值根据Kafka实例中的安全协议填写为SASL_SSLSASL_PLAINTEXT
  • 当DMS Kafka实例的连接信息中配置SASL认证机制后,需要添加认证方式的属性:属性名称填写为sasl.mechanism,值根据Kafka实例中配置的SASL认证机制填写为PLAINSCRAM-SHA-512(同时支持时选择其中任意一种填写即可)。

-