DMS Kafka连接
介绍
通过DMS Kafka连接,可以连接DMS Kafka普通队列或者专享版Kafka。目前仅支持从DMS Kafka导出数据到云搜索服务。
连接样例
{ "links": [ { "link-config-values": { "configs": [ { "inputs": [ { "name": "linkConfig.kafkaType", "value": "Platinum" }, { "name": "linkConfig.brokerList", "value": "100.85.121.112:9094,100.85.220.134:9094,100.85.127.232:9094" }, { "name": "linkConfig.isPlatinumInstance", "value": "false" } ], "name": "linkConfig" } ], "extended-configs": { "name": "linkConfig.extendedFields", "value": "e30=" } }, "name": "dms_kafka", "connector-name": "dms-kafka-connector" } ] }
连接参数
参数 |
是否必选 |
类型 |
说明 |
---|---|---|---|
linkConfig.kafkaType |
是 |
枚举 |
选择DMS Kafka版本,目前只有专享版。
|
linkConfig.brokerList |
是 |
String |
DMS Endpoint格式为“host1:port1,host2:port2”。 |
linkConfig.isPlatinumInstance |
是 |
Boolean |
选择是否打开客户端连接Kafka专享版实例时SSL认证的开关。 开启Kafka SASL_SSL,则数据加密传输,安全性更高,但性能会下降。 |
linkConfig.user |
否 |
String |
开启Kafka SASL_SSL时显示该参数,表示连接DMS Kafka的用户名。 |
linkConfig.password |
否 |
String |
开启Kafka SASL_SSL时显示该参数,表示连接DMS Kafka的密码。 |