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

{
    "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"
            }
        }
    }
}

400

Invalid Request sent by the user

Operation doesn't return any data structure

401

User authentication failed

Operation doesn't return any data structure

403

Access to the requested resource/operation is forbidden

Operation doesn't return any data structure

404

Cannot find requested resource

Operation doesn't return any data structure