更新时间:2023-06-15 GMT+08:00
        
          
          
        
      
      
      
      
      
      
      
      
  
      
      
      
        
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的密码。  | 
     
   父主题: 连接参数说明