
How to add Kafka Schema Registry MCP Server to Cursor
Manage Kafka Schema Registry from Claude — register, evolve, compare, migrate, and export Avro schemas in plain language. Paste the config into ~/.cursor/mcp.json and restart Cursor.
Last updated June 14, 2026 · 31★ · stdio · oauth
Cursor 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
- 1Open Cursor → Settings → MCP → Add new MCP server (or edit ~/.cursor/mcp.json directly).
- 2Paste the Kafka Schema Registry MCP Server config below into the "mcpServers" object.
- 3Fill in placeholder secrets, then save.
- 4Cursor reloads MCP servers automatically — check Settings → MCP for a green status dot.
- 5Ask Cursor to use one of Kafka Schema Registry MCP Server's tools to confirm it's connected.
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 Cursor
pingMCP ping/pong server health check.
set_default_registrySet the default registry (admin scope).
get_default_registryGet the current default registry.
register_schemaRegister a new schema version (write scope).
check_compatibilityCheck schema compatibility (BACKWARD, FORWARD, FULL).
create_contextCreate a new schema context for environment isolation.
delete_contextDelete a context (admin scope).
delete_subjectDelete 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 + Cursor FAQ
Where is the Cursor config file?
Cursor reads MCP servers from ~/.cursor/mcp.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 Cursor?
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.