aywengo/kafka-schema-reg-mcp

Kafka Schema Registry MCP Server

A comprehensive MCP (Model Context Protocol) server that provides *** Desktop and other MCP clients with tools for Kafka Schema Registry operations. True MCP implementation using the official SDK with JSON-RPC over stdio.

✨ Key Features

• 🤖 *** Desktop Compatible: Direct integration via MCP protocol
• 📋 48 MCP Tools: Complete schema operations via natural language
• 🌐 Multi-Registry Support: Connect to up to 8 Schema Registry instances
• ⚡ Async Operations: Non-blocking tasks with real-time progress tracking
• 🔧 Context Management: Logical grouping with separate "sub-registries"
• 🚀 Simplified Migration: Ready-to-run Docker commands for context migration
• 🔒 Production Ready: Per-registry VIEWONLY mode, authentication support
• 📦 Multi-Platform: AMD64 and ARM64 architectures

🚀 Quick Start

Pull the Image

bash
# Latest stable release (recommended)
docker pull aywengo/kafka-schema-reg-mcp:stable

# Latest development
docker pull aywengo/kafka-schema-reg-mcp:latest

SLIM_MODE for Better Performance

To reduce *** overhead, run with SLIM_MODE enabled:

bash
# Run with ~15 essential tools instead of 53+
docker run -i --rm --network host \
  -e SCHEMA_REGISTRY_URL=http://localhost:8081 \
  -e SLIM_MODE=true \
  aywengo/kafka-schema-reg-mcp:stable

💡 SLIM_MODE Benefits:

• Reduces tool count from 53+ to ~15 essential tools
• Significantly faster *** response times
• Lower token usage and reduced costs
• Ideal for production read-only operations
• Simply set SLIM_MODE=true environment variable

Single Registry Mode

bash
docker run -i --rm --network host \
  -e SCHEMA_REGISTRY_URL=http://localhost:8081 \
  aywengo/kafka-schema-reg-mcp:stable

Multi-Registry Mode

bash
docker run -i --rm --network host \
  -e SCHEMA_REGISTRY_NAME_1=development \
  -e SCHEMA_REGISTRY_URL_1=http://dev-registry:8081 \
  -e SCHEMA_REGISTRY_NAME_2=production \
  -e SCHEMA_REGISTRY_URL_2=http://prod-registry:8081 \
  -e VIEWONLY_2=true \
  aywengo/kafka-schema-reg-mcp:stable

🤖 *** Desktop Integration

Add to your *** Desktop configuration (~/Library/Application Support/Claude/claude_desktop_config.json on macOS):

Single Registry

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

Multi-Registry

json
{
  "mcpServers": {
    "kafka-schema-registry-multi": {
      "command": "docker",
      "args": [
        "run", "--rm", "-i", "--network", "host",
        "-e", "SCHEMA_REGISTRY_NAME_1", "-e", "SCHEMA_REGISTRY_URL_1",
        "-e", "SCHEMA_REGISTRY_NAME_2", "-e", "SCHEMA_REGISTRY_URL_2", "-e", "VIEWONLY_2",
        "aywengo/kafka-schema-reg-mcp:stable"
      ],
      "env": {
        "SCHEMA_REGISTRY_NAME_1": "development",
        "SCHEMA_REGISTRY_URL_1": "http://localhost:8081",
        "SCHEMA_REGISTRY_NAME_2": "production", 
        "SCHEMA_REGISTRY_URL_2": "http://localhost:8082",
        "VIEWONLY_2": "true"
      }
    }
  }
}

🗣️ Natural Language Usage

With *** Desktop, use natural language commands:

"List all schema contexts"
"Register a user schema with id, name, and email fields"
"Migrate all schemas from staging to production"
"Compare development and production registries"
"Export all schemas from the production context"
"Check if my updated schema is compatible"

🔧 Configuration

Environment Variables

📋 Key MCP Tools

• Schema Operations: register_schema, get_schema, check_compatibility
• Context Management: list_contexts, create_context, migrate_context
• Multi-Registry: compare_registries, migrate_schema, test_registry_connection
• Configuration: update_global_config, get_subject_config
• Export: export_schema, export_context, export_global
• Task Management: get_task_progress, list_all_active_tasks

🔒 VIEWONLY Mode

Set VIEWONLY=true for production safety:

• ✅ Allowed: Schema browsing, compatibility checking, exports
• ❌ Blocked: Schema registration, deletion, configuration changes

🚀 Context Migration

The migrate_context tool generates ready-to-run Docker commands using the external https://github.com/aywengo/kafka-schema-reg-migrator:

"Migrate staging context to production"
→ Returns: docker run command with automatic credential mapping
→ Features: Copy-paste execution, no file setup required

📚 Links

• GitHub: https://github.com/aywengo/kafka-schema-reg-mcp
• Documentation: Full guides and API reference in repository
• License: MIT License

Ready to start? Pull the Docker image and configure *** Desktop to manage your Kafka Schema Registry with natural language! 🚀