更新时间:2024-01-16 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版本,目前只有专享版。

  • 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的密码。