Connectors endpoint v2

Manage connectors — the source and destination integrations pipelines read from and write to.

Create a connector

POST /v2/connectors

Name Type Required Description
typestringYesOne of postgres, s3, snowflake, kafka, webhook.
directionstringYessource, destination, or bidirectional (webhook only).
configobjectYesType-specific connection details, e.g. connection string or IAM role ARN.
create-connector.sh bash
curl -X POST https://api.kmp.kaiju.go.example/v2/connectors \
  -H "Authorization: Bearer $KMP_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "type": "postgres",
    "direction": "source",
    "config": { "connection_string": "postgres://..." }
  }'

Rotate credentials

POST /v2/connectors/{id}/rotate — pauses every pipeline referencing this connector for the duration of the rotation, then resumes them automatically.

Shared connectors

A connector referenced by multiple pipelines is rotated once, for all of them. Check a connector's pipeline_count field before rotating during a busy window.

Health status

GET /v2/connectors/{id} returns a health field of healthy, degraded, or down.