MCP Directory

How to add Kafka Schema Registry MCP Server to Windsurf

Manage Kafka Schema Registry from Claude — register, evolve, compare, migrate, and export Avro schemas in plain language. Paste the config into ~/.codeium/windsurf/mcp_config.json and restart Windsurf.

Last updated June 14, 2026 · 31★ · stdio · oauth

Windsurf config for Kafka Schema Registry MCP Server

docker pull aywengo/kafka-schema-reg-mcp:stable
{
  "mcpServers": {
    "kafka-schema-registry-mcp-server": {
      "command": "docker",
      "args": [
        "run",
        "--rm",
        "-i",
        "--network",
        "host",
        "-e",
        "SCHEMA_REGISTRY_URL",
        "-e",
        "SCHEMA_REGISTRY_USER",
        "-e",
        "SCHEMA_REGISTRY_PASSWORD",
        "aywengo/kafka-schema-reg-mcp:stable"
      ],
      "env": {
        "SCHEMA_REGISTRY_URL": "http://localhost:38081",
        "SCHEMA_REGISTRY_USER": "",
        "SCHEMA_REGISTRY_PASSWORD": ""
      }
    }
  }
}

Requires Docker to be installed and running.

Setup steps

  1. 1Open Windsurf → Cascade → the hammer/MCP icon → Configure (or edit ~/.codeium/windsurf/mcp_config.json).
  2. 2Paste the Kafka Schema Registry MCP Server config below.
  3. 3Fill in placeholder secrets, then save.
  4. 4Click Refresh in the MCP panel.
  5. 5Kafka Schema Registry MCP Server's tools become available to Cascade.

Before you start

  • Docker (recommended) or Python 3.10+
  • A reachable Kafka Schema Registry instance (SCHEMA_REGISTRY_URL)
  • Optional: OAuth 2.1 provider (Azure AD, Google, Keycloak, Okta, or GitHub) for authentication

What Kafka Schema Registry MCP Server can do in Windsurf

ping

MCP ping/pong server health check.

set_default_registry

Set the default registry (admin scope).

get_default_registry

Get the current default registry.

register_schema

Register a new schema version (write scope).

check_compatibility

Check schema compatibility (BACKWARD, FORWARD, FULL).

create_context

Create a new schema context for environment isolation.

delete_context

Delete a context (admin scope).

delete_subject

Delete a subject and all its versions (admin scope).

Security

Supports optional OAuth 2.1 authentication (ENABLE_AUTH=true with AUTH_ISSUER_URL and AUTH_AUDIENCE) with read/write/admin scope-based authorization. Production safety features include VIEWONLY mode (per-registry), SSRF protection via URL validation with configurable localhost access, and per-registry access controls. The config-examples block runs the server via Docker with --network host; restrict SCHEMA_REGISTRY_URL and credentials appropriately for production registries.

Kafka Schema Registry MCP Server + Windsurf FAQ

Where is the Windsurf config file?

Windsurf reads MCP servers from ~/.codeium/windsurf/mcp_config.json. Paste the Kafka Schema Registry MCP Server config there under the "mcpServers" key and restart the client.

Is Kafka Schema Registry MCP Server safe to use with Windsurf?

Supports optional OAuth 2.1 authentication (ENABLE_AUTH=true with AUTH_ISSUER_URL and AUTH_AUDIENCE) with read/write/admin scope-based authorization. Production safety features include VIEWONLY mode (per-registry), SSRF protection via URL validation with configurable localhost access, and per-registry access controls. The config-examples block runs the server via Docker with --network host; restrict SCHEMA_REGISTRY_URL and credentials appropriately for production registries.

What is SLIM_MODE and when should I use it?

SLIM_MODE (SLIM_MODE=true) reduces the exposed tool set from 50+ to ~9 essential tools, lowering token usage and speeding up LLM responses. It is recommended for most day-to-day and read-only operations; disable it (SLIM_MODE=false) when you need migrations, batch cleanup, or guided workflows.

Does it support multiple Schema Registry instances?

Yes. It supports up to 8 registries simultaneously via numbered environment variables (e.g. SCHEMA_REGISTRY_NAME_1 / SCHEMA_REGISTRY_URL_1), each with independent VIEWONLY settings.

How do I run it?

Pull and run the Docker image aywengo/kafka-schema-reg-mcp:stable, or clone the repo and run python kafka_schema_registry_unified_mcp.py with requirements installed. Configure Claude Desktop with the provided config-examples mcpServers block.

View repo Full Kafka Schema Registry MCP Server page