Kafka Connect

get

Authorizations

bearerAuthcookieAuth

AuthorizationstringRequired

The bearer token can be obtained by creating a ServiceAccount.

Path parameters

environmentstringRequired

Query parameters

clusterstring[]Optional

classNamestring[]Optional

Responses

200Success

application/json

400

The request input was invalid

application/json

401

Authentication error

application/json

402

The purchased Lenses license does not provide access to this feature

application/json

403

Authorisation error

application/json

404

The requested resource cannot be found

application/json

500

An internal server error has occurred

application/json

get

/api/v1/environments/{environment}/proxy/api/kafka-connect/connectors

HTTPcURLJavaScriptPython

GET /api/v1/environments/{environment}/proxy/api/kafka-connect/connectors HTTP/1.1
Host: api.example.com
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{
  "data": [
    {
      "name": "text",
      "lrn": "text",
      "cluster": "text",
      "state": "RUNNING",
      "tasks": [
        {
          "id": 1,
          "state": "RUNNING"
        }
      ],
      "className": "text",
      "type": "text",
      "author": "text",
      "icon": "text"
    }
  ]
}

post

Authorizations

bearerAuthcookieAuth

AuthorizationstringRequired

The bearer token can be obtained by creating a ServiceAccount.

Path parameters

environmentstringRequired

Body

application/json

namestring · min: 1Required

clusterstring · min: 1Required

Responses

200Success

application/json

400

The request input was invalid

application/json

401

Authentication error

application/json

402

The purchased Lenses license does not provide access to this feature

application/json

403

Authorisation error

application/json

404

The requested resource cannot be found

application/json

500

An internal server error has occurred

application/json

post

/api/v1/environments/{environment}/proxy/api/kafka-connect/connectors

HTTPcURLJavaScriptPython

POST /api/v1/environments/{environment}/proxy/api/kafka-connect/connectors HTTP/1.1
Host: api.example.com
Authorization: Bearer YOUR_SECRET_TOKEN
Content-Type: application/json
Accept: */*
Content-Length: 108

{
  "name": "connector",
  "cluster": "cluster",
  "configuration": {
    "connector.class": "org...FileStreamSinkConnector"
  }
}

{}

get

Authorizations

bearerAuthcookieAuth

AuthorizationstringRequired

The bearer token can be obtained by creating a ServiceAccount.

Path parameters

environmentstringRequired

clusterstring · min: 1Required

connectorstring · min: 1Required

Responses

200Success

application/json

400

The request input was invalid

application/json

401

Authentication error

application/json

402

The purchased Lenses license does not provide access to this feature

application/json

403

Authorisation error

application/json

404

The requested resource cannot be found

application/json

500

An internal server error has occurred

application/json

get

/api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector}

HTTPcURLJavaScriptPython

GET /api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector} HTTP/1.1
Host: api.example.com
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{
  "name": "text",
  "lrn": "text",
  "state": "RUNNING",
  "type": "text",
  "className": "text",
  "workerId": "text",
  "version": "text",
  "author": "text",
  "icon": "text",
  "cluster": "text",
  "config": {
    "ANY_ADDITIONAL_PROPERTY": "text"
  },
  "tasks": [
    {
      "id": "text",
      "state": "text",
      "workerId": "text",
      "trace": "text"
    }
  ],
  "code": "text",
  "__errors": [
    {
      "field": "text",
      "reason": "text"
    }
  ]
}

delete

Authorizations

bearerAuthcookieAuth

AuthorizationstringRequired

The bearer token can be obtained by creating a ServiceAccount.

Path parameters

environmentstringRequired

clusterstring · min: 1Required

connectorstring · min: 1Required

Responses

200Success

application/json

400

The request input was invalid

application/json

401

Authentication error

application/json

402

The purchased Lenses license does not provide access to this feature

application/json

403

Authorisation error

application/json

404

The requested resource cannot be found

application/json

500

An internal server error has occurred

application/json

delete

/api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector}

HTTPcURLJavaScriptPython

DELETE /api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector} HTTP/1.1
Host: api.example.com
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{}

get

Authorizations

bearerAuthcookieAuth

AuthorizationstringRequired

The bearer token can be obtained by creating a ServiceAccount.

Path parameters

environmentstringRequired

Query parameters

clusterstring[]Optional

Responses

200Success

application/json

400

The request input was invalid

application/json

401

Authentication error

application/json

402

The purchased Lenses license does not provide access to this feature

application/json

403

Authorisation error

application/json

404

The requested resource cannot be found

application/json

500

An internal server error has occurred

application/json

get

/api/v1/environments/{environment}/proxy/api/kafka-connect/plugins

HTTPcURLJavaScriptPython

GET /api/v1/environments/{environment}/proxy/api/kafka-connect/plugins HTTP/1.1
Host: api.example.com
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{
  "data": [
    {
      "class": "text",
      "cluster": "text",
      "name": "text",
      "type": "text",
      "version": "text",
      "author": "text",
      "icon": "text",
      "description": "text",
      "docs": "text"
    }
  ]
}

put

Authorizations

bearerAuthcookieAuth

AuthorizationstringRequired

The bearer token can be obtained by creating a ServiceAccount.

Path parameters

environmentstringRequired

clusterstring · min: 1Required

connectorstring · min: 1Required

actionstring · enumRequiredPossible values:

Responses

200Success

application/json

400

The request input was invalid

application/json

401

Authentication error

application/json

402

The purchased Lenses license does not provide access to this feature

application/json

403

Authorisation error

application/json

404

The requested resource cannot be found

application/json

500

An internal server error has occurred

application/json

put

/api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector}/{action}

HTTPcURLJavaScriptPython

PUT /api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector}/{action} HTTP/1.1
Host: api.example.com
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{}

put

Authorizations

bearerAuthcookieAuth

AuthorizationstringRequired

The bearer token can be obtained by creating a ServiceAccount.

Path parameters

environmentstringRequired

clusterstring · min: 1Required

connectorstring · min: 1Required

p1integerRequired

Responses

200Success

application/json

400

The request input was invalid

application/json

401

Authentication error

application/json

402

The purchased Lenses license does not provide access to this feature

application/json

403

Authorisation error

application/json

404

The requested resource cannot be found

application/json

500

An internal server error has occurred

application/json

put

/api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector}/tasks/{p1}/restart

HTTPcURLJavaScriptPython

PUT /api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector}/tasks/{p1}/restart HTTP/1.1
Host: api.example.com
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{}

post

Authorizations

bearerAuthcookieAuth

AuthorizationstringRequired

The bearer token can be obtained by creating a ServiceAccount.

Path parameters

environmentstringRequired

Body

application/json

namestringRequired

clusterstringRequired

Responses

200Success

application/json

400

The request input was invalid

application/json

401

Authentication error

application/json

402

The purchased Lenses license does not provide access to this feature

application/json

403

Authorisation error

application/json

404

The requested resource cannot be found

application/json

500

An internal server error has occurred

application/json

post

/api/v1/environments/{environment}/proxy/api/kafka-connect/validate

HTTPcURLJavaScriptPython

POST /api/v1/environments/{environment}/proxy/api/kafka-connect/validate HTTP/1.1
Host: api.example.com
Authorization: Bearer YOUR_SECRET_TOKEN
Content-Type: application/json
Accept: */*
Content-Length: 108

{
  "name": "connector",
  "cluster": "cluster",
  "configuration": {
    "connector.class": "org...FileStreamSinkConnector"
  }
}

{
  "class": "text",
  "configuration": [
    {
      "name": "text",
      "required": true,
      "order": 1,
      "documentation": "text",
      "errors": [
        "text"
      ],
      "visible": true,
      "value": "text",
      "defaultValue": "text"
    }
  ]
}