mcp-kafka-connect client

The mcp-kafka-connect client binding exposes the Kafka Connect REST API as a fixed set of intrinsic MCP tools, connecting directly to the Kafka Connect worker named by options.server — unlike mcp-openapi, there is no upstream spec or per-tool schema to author. mcp-kafka and mcp-schema-registry follow the same fixed-tool pattern for the Kafka broker and schema registry APIs.

mcp_kafka_connect_client:
  type: mcp-kafka-connect
  kind: client
  options:
    server: http://kafka-connect.examples.dev:8083
  routes:
    - when:
        - tool: create_connector
        - tool: delete_connector
        - tool: update_connector_config
        - tool: restart_connector
        - tool: pause_connector
        - tool: resume_connector
        - tool: stop_connector
        - tool: restart_connector_task
        - tool: alter_connector_offsets
        - tool: reset_connector_offsets
      guarded:
        my_guard:
          - kafka-connect:admin
    - when:
        - tool: "*"

Configuration (* required)

options*

object

The client specific options.

options:
  server: http://kafka-connect.examples.dev:8083

options.server*

string

Base URL of the Kafka Connect REST API this binding proxies to.

routes*

array of object

Conditional mcp-kafka-connect specific routes, matching by tool name or glob pattern. At least one route is required. Routes are evaluated in order; the first matching route wins.

routes:
  - when:
      - tool: delete_connector
    guarded:
      my_guard:
        - kafka-connect:admin
  - when:
      - tool: "*"

routes[].when*

array of object

List of conditions (any match) restricting this route to particular tools. Required.

routes:
  - when:
      - tool: create_connector
      - tool: delete_connector

when[].tool*

string or array of string

Tool name matched by tools/call, or a * glob pattern matching many tool names in bulk (such as list_*). Required.

routes[].guarded

object as map of named array of string

Roles required by the named guard for a tools/call against this route. Roles for the same guard are unioned into one entry; roles naming a different guard add a separate entry that must also authorize.

routes:
  - when:
      - tool: delete_connector
    guarded:
      my_guard:
        - kafka-connect:admin

telemetry

object

Defines the desired telemetry for the binding.

telemetry.metrics

array

Telemetry metrics to track

telemetry:
  metrics:
    - stream.*

telemetry.attributes

object as map of named string properties

Telemetry attributes to add to the binding metrics.

Tools

The mcp-kafka-connect client exposes a fixed set of intrinsic tools, derived from a bundled Kafka Connect REST API specification — there is no options.tools to author, and no upstream server or spec to select. Each tool's inputSchema validates tools/call arguments before Zilla dispatches the matching request to options.server. Every tool's structuredContent carries the upstream JSON response — validated and pruned to a declared outputSchema where one exists, or the raw body unchanged where none is declared — and content carries the tool's summary text, which may itself interpolate fields out of that same response via ${result.x}.

list_connectors

Read-only, idempotent

Lists the names of every connector on the worker.

No arguments.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response — an array of connector names — with no fixed property list.

create_connector

Not destructive, not idempotent

Creates a new connector.

Argument	Type	Required	Description
`name`	`string`	No	Connector name.
`config`	`object` as map of named `string`	No	Connector configuration properties.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.name}.

describe_connector

Read-only, idempotent

Reads one connector's configuration and task list by name.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector to describe.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.name}.

delete_connector

Destructive, idempotent

Deletes a connector.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector to delete.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.name}.

describe_connector_config

Read-only, idempotent

Reads the effective configuration of a connector.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector to read the configuration of.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list.

update_connector_config

Not destructive, idempotent

Creates or updates a connector by setting its full configuration.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector to configure.
`connector.class`	`string`	No	Connector class to instantiate.
`tasks.max`	`string`	No	Maximum number of tasks to run.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.name}.

validate_connector_config

Read-only, idempotent

Validates a connector configuration against a plugin's configuration definition, without creating or updating any connector.

Argument	Type	Required	Description
`pluginName`	`string`	Yes	Connector plugin to validate against.
`connector.class`	`string`	No	Connector class to validate.
`tasks.max`	`string`	No	Maximum number of tasks to validate.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.error_count}, such as Validated connector config with 0 errors.

describe_connector_status

Read-only, idempotent

Reads a connector's current state and the state of each of its tasks.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector to check the status of.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.name} and ${result.connector.state}, such as Connector my-connector is RUNNING.

restart_connector

Not destructive, not idempotent

Restarts a connector.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector to restart.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.name}.

pause_connector

Not destructive, idempotent

Pauses a connector and all of its tasks.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector to pause.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.name}.

resume_connector

Not destructive, idempotent

Resumes a paused connector and all of its tasks.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector to resume.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.name}.

stop_connector

Not destructive, idempotent

Stops a connector and shuts down all of its tasks, without deleting the connector.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector to stop.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.name}.

list_connector_tasks

Read-only, idempotent

Lists every task belonging to a connector.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector whose tasks to list.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list.

restart_connector_task

Not destructive, not idempotent

Restarts a single task belonging to a connector.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector owning the task.
`task`	`integer`	Yes	Task id to restart.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list.

describe_connector_offsets

Read-only, idempotent

Reads a connector's current source or sink offsets.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector whose offsets to read.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list.

alter_connector_offsets

Destructive, idempotent

Overwrites a connector's source or sink offsets. The connector must be stopped first.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector whose offsets to alter.
`offsets`	`array` of `object`	No	Offsets to write.
`offsets[].partition`	`object`	No	Source partition or sink topic-partition identifying the offset.
`offsets[].offset`	`object`	No	New offset value for the identified partition.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.message}.

reset_connector_offsets

Destructive, idempotent

Resets a connector's source or sink offsets to their initial state. The connector must be stopped first.

Argument	Type	Required	Description
`connector`	`string`	Yes	Connector whose offsets to reset.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response, with no fixed property list. The summary interpolates ${result.message}.

list_connector_plugins

Read-only, idempotent

Lists every connector plugin installed on the worker.

No arguments.

No fixed outputSchema is declared; the result's structuredContent mirrors the raw upstream JSON response — an array of installed plugins — with no fixed property list.