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版本,目前只有专享版。 Basic：指DMS Kafka普通队列。 Platinum：指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的密码。