---
title: "POST /v1/{+parent}/connectors"
method: POST
path: "/v1/{+parent}/connectors"
tags: ["projects"]
---

# POST /v1/{+parent}/connectors

`POST /v1/{+parent}/connectors`

Creates a new connector in a given Connect cluster.

## Path parameters

- `parent` string, required

## Query parameters

- `connectorId` string

## Request body

- Connector — A Kafka Connect connector in a given ConnectCluster.
  - `state` 'STATE_UNSPECIFIED' | 'UNASSIGNED' | 'RUNNING' | 'PAUSED' | 'FAILED' | 'RESTARTING' | 'STOPPED' — Output only. The current state of the connector.
  - `taskRestartPolicy` TaskRetryPolicy — Task Retry Policy is implemented on a best-effort basis. The default policy retries tasks with a minimum_backoff of 60 seconds, and a maximum_backoff of 12 hours. You can disable the policy by setting the task_retry_disabled field to true. Retry delay will be exponential based on provided minimum and maximum backoffs. https://en.wikipedia.org/wiki/Exponential_backoff. Note that the delay between consecutive task restarts may not always precisely match the configured settings. This can happen when the ConnectCluster is in rebalancing state or if the ConnectCluster is unresponsive etc. The default values for minimum and maximum backoffs are 60 seconds and 12 hours respectively.
    - `maximumBackoff` string, google-duration — Optional. The maximum amount of time to wait before retrying a failed task. This sets an upper bound for the backoff delay.
    - `taskRetryDisabled` boolean — Optional. If true, task retry is disabled.
    - `minimumBackoff` string, google-duration — Optional. The minimum amount of time to wait before retrying a failed task. This sets a lower bound for the backoff delay.
  - `name` string — Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}
  - `configs` object — Optional. Connector config as keys/values. The keys of the map are connector property names, for example: `connector.class`, `tasks.max`, `key.converter`.

## Response `200`

Successful response

---

[API](https://skmtc.net/google/apis/managedkafka.md) · [All operations](https://skmtc.net/google/apis/managedkafka/llms.txt) · [OpenAPI document](https://skmtc-service-staging.skmtc.workers.dev/v1/apis/google/managedkafka/versions/ebfb70483869/schema)