Upsert connector configuration Run in API Explorer

PUT /v1/kafka-connect/clusters/{cluster_name}/connectors/{name}/config

Update the configuration for an existing connector with the specified name, or create a new connector using the given configuration. Returns information about the connector after the change has been made.

Path parameters

  • cluster_name string Required

    Unique name of target connect cluster. For Redpanda Cloud, use redpanda.

  • name string Required

    Name of connector. If a connector with this name does not already exist, a new connector is created.

application/json

Body Required

Connector configuration property.

  • config Required
  • * string Additional properties

Responses

  • 200 application/json

    Updated

    Hide response attribute Show response attribute object
    • connector object

      Connector specifications as defined in the Kafka Connect API. You may include this in the request body when creating a new connector.

      Hide connector attributes Show connector attributes object
      • config object Required

        Connector configuration properties.

        Hide config attribute Show config attribute object
        • * string Additional properties
      • name string Required

        Name of connector.

      • tasks array[object]
        Hide tasks attributes Show tasks attributes object
        • connector string

          Name of connector.

        • task integer(int32)

          The connector task ID.

      • type string
  • 201 application/json

    Created

    Hide response attributes Show response attributes object
    • config object Required

      Connector configuration properties.

      Hide config attribute Show config attribute object
      • * string Additional properties
    • name string Required

      Name of connector.

    • tasks array[object]
      Hide tasks attributes Show tasks attributes object
      • connector string

        Name of connector.

      • task integer(int32)

        The connector task ID.

    • type string
  • 401 application/json

    Unauthenticated.

    Hide response attributes Show response attributes object
    • code string(int32)

      RPC status code, as described here.

      Values are OK, CANCELLED, UNKNOWN, INVALID_ARGUMENT, DEADLINE_EXCEEDED, NOT_FOUND, ALREADY_EXISTS, PERMISSION_DENIED, UNAUTHENTICATED, RESOURCE_EXHAUSTED, FAILED_PRECONDITION, ABORTED, OUT_OF_RANGE, UNIMPLEMENTED, INTERNAL, UNAVAILABLE, or DATA_LOSS.

    • details array[object]

      A list of messages that carries the error details.

      Details of the error.

      Details of the error.

      One of:
    • message string

      Detailed error message. No compatibility guarantees are given for the text contained in this message.

  • 500 application/json

    Internal Server Error. Reach out to support.

    Hide response attributes Show response attributes object
    • code string(int32)

      RPC status code, as described here.

      Values are OK, CANCELLED, UNKNOWN, INVALID_ARGUMENT, DEADLINE_EXCEEDED, NOT_FOUND, ALREADY_EXISTS, PERMISSION_DENIED, UNAUTHENTICATED, RESOURCE_EXHAUSTED, FAILED_PRECONDITION, ABORTED, OUT_OF_RANGE, UNIMPLEMENTED, INTERNAL, UNAVAILABLE, or DATA_LOSS.

    • details array[object]

      A list of messages that carries the error details.

      Details of the error.

      Details of the error.

      One of:
    • message string

      Detailed error message. No compatibility guarantees are given for the text contained in this message.

  • default application/json

    An unexpected error response.

    Hide response attributes Show response attributes object
    • code string(int32)

      RPC status code, as described here.

      Values are OK, CANCELLED, UNKNOWN, INVALID_ARGUMENT, DEADLINE_EXCEEDED, NOT_FOUND, ALREADY_EXISTS, PERMISSION_DENIED, UNAUTHENTICATED, RESOURCE_EXHAUSTED, FAILED_PRECONDITION, ABORTED, OUT_OF_RANGE, UNIMPLEMENTED, INTERNAL, UNAVAILABLE, or DATA_LOSS.

    • details array[object]

      A list of messages that carries the error details.

      Details of the error.

      Details of the error.

      One of:
    • message string

      Detailed error message. No compatibility guarantees are given for the text contained in this message.

PUT /v1/kafka-connect/clusters/{cluster_name}/connectors/{name}/config
curl \
 --request PUT 'https://{dataplane_api_subdomain}.cloud.redpanda.com/v1/kafka-connect/clusters/{cluster_name}/connectors/{name}/config' \
 --header "Authorization: Bearer $ACCESS_TOKEN" \
 --header "Content-Type: application/json" \
 --data '{"additionalProperty1":"string","additionalProperty2":"string"}'
Request examples
{
  "additionalProperty1": "string",
  "additionalProperty2": "string"
}
Response examples (200)
{
  "connector": {
    "config": {
      "additionalProperty1": "string",
      "additionalProperty2": "string"
    },
    "name": "string",
    "tasks": [
      {
        "connector": "string",
        "task": 42
      }
    ],
    "type": "string"
  }
}
Response examples (201)
{
  "config": {
    "additionalProperty1": "string",
    "additionalProperty2": "string"
  },
  "name": "string",
  "tasks": [
    {
      "connector": "string",
      "task": 42
    }
  ],
  "type": "string"
}
Response examples (401)
{
  "code": "OK",
  "details": [
    {
      "@type": "type.googleapis.com/google.rpc.BadRequest",
      "field_violations": [
        {
          "description": "string",
          "field": "string"
        }
      ]
    }
  ],
  "message": "string"
}
Response examples (500)
{
  "code": "OK",
  "details": [
    {
      "@type": "type.googleapis.com/google.rpc.BadRequest",
      "field_violations": [
        {
          "description": "string",
          "field": "string"
        }
      ]
    }
  ],
  "message": "string"
}
Response examples (default)
{
  "code": "OK",
  "details": [
    {
      "@type": "type.googleapis.com/google.rpc.BadRequest",
      "field_violations": [
        {
          "description": "string",
          "field": "string"
        }
      ]
    }
  ],
  "message": "string"
}