Overview
Get source catalog
Retrieves the schema catalog (schemas, tables, columns) from a source database connection.
Send command to connector
Send a control command (start, stop, pause, resume) to a specific connector
Get connector history
Retrieve the configuration history for a specific connector
List all connectors
Retrieve a list of all connectors with their status
Create a new connector
Create a new connector. The server generates a unique identifier, ignoring any id in the request body. Note: the id field is still required in the request body for schema validation; use a placeholder value like an empty string.
Get connector by ID
Retrieve a specific connector by its ID with status information
Create or update a connector with a specified ID
Create or update a connector. The connector_id in the URL path is authoritative and overrides any id in the request body. If a connector with this ID already exists, it will be replaced. When clone_from is provided, secret fields (passwords, certificates) are copied from the source connector.
Update an existing connector (JSON Merge Patch)
Updates an existing connector following JSON Merge Patch (RFC 7396). Only fields present in the request body are updated. Fields absent are unchanged. Optional fields set to null are cleared. Source/sink type and immutable fields (host, port, database, http_url) cannot be modified.
Debug connector configuration
Validate and debug a connector configuration without storing it
Validate buffer configuration
Tests connection and permissions for a buffer configuration.
Validate sink connector configuration
Tests connection, authentication, permissions, and configuration for target.
Validate source connector configuration
Tests connection, authentication, permissions, and configuration for source.
Get snapshot status
Returns snapshot status for graceful shutdown coordination. Use with Kubernetes preStop hooks.