Create Connector | Telco Cloud Service Assurance

Create Connector

Create a connector instance

Request

URI

POST

https://{api_host}/tcsa.host.com/dcc/v1/connectors

COPY

Request Body

Create a new connector instance such as kafka connector

CreateConnectorRequest of type(s) application/json

Required

Show optional properties

{
    "targetCluster": {
        "tls": {},
        "authentication": {},
        "bootstrapServers": "10.168.200.123:9092"
    },
    "name": "DashboardKafka",
    "topics": [
        "vsa_metrics",
        "vsa_events"
    ]
}

{
    "name": "demo_connector",
    "tasksMax": 6,
    "replicationFactor": 2,
    "topics": [
        "vsa_metrics"
    ],
    "targetCluster": {
        "bootstrapServers": "target-kafka-cluster:9092",
        "tls": {
            "enabled": true,
            "certificate": "base64 encoded certificate"
        },
        "authentication": {
            "enabled": true,
            "type": "auth type plain/scram-sha-512/oauth/tls",
            "username": "targetuser",
            "password": "target password"
        }
    },
    "logging": {
        "type": "inline",
        "level": "INFO"
    },
    "resources": {
        "limits": {
            "cpu": "4000m",
            "memory": "8192Mi"
        },
        "requests": {
            "cpu": "1000m",
            "memory": "2048Mi"
        }
    }
}

string As ^[A-Za-z]

name

Required

Name of the connector should always start with a letter a-z or A-Z

number

tasksMax

Optional

The maximum number of tasks for the Kafka Connector.

number

replicationFactor

Optional

Replication factor for the internal topics and replicated topics.

array of string

topics

Required

Topic names to be replicated

TargetClusterObject

targetCluster

Required

Object having details of target kafka cluster and authentication

LoggingObject

logging

Optional

Logging object containing logging type and logging level

ResourcesObject

resources

Optional

Maximum limits for CPU and memory resources and the requested initial resources.

Authentication

This operation uses the following authentication methods.

bearerAuth

Responses

200

Returns Connector Config for the newly created Connector

Returns CreateConnectorResponse of type(s) application/json

{
    "message": "Connector successfully initialized",
    "blockId": "kafka-connector",
    "time": "2022-03-25 13:02:21.041469",
    "name": "demo_connector",
    "instanceId": "demo-connector",
    "display_name": "Demo_connector",
    "status": "pending",
    "params": {
        "targetCluster": {
            "tls": null,
            "authentication": null,
            "bootstrapServers": "10.168.200.123:9092"
        },
        "name": "DashboardKafka",
        "topics": [
            "vsa_metrics",
            "vsa_events"
        ],
        "tasksMax": 4,
        "resources": {
            "requests": {
                "memory": "2Gi",
                "cpu": "1"
            },
            "limits": {
                "memory": "8Gi",
                "cpu": "4"
            }
        }
    }
}

string

blockId

Optional

The type of connector created.

string

displayName

Optional

The name of the connector as entered by the user

string

instanceId

Optional

Instance id of the connector object