aywengo/kafka-schema-reg-mcp

By aywengo

•Updated 24 days ago

MCP Server for Kafka Schema Registry - 70+ tools, OAuth, multi-registry, Kubernetes ready

Image

API management

Machine learning & AI

Monitoring & observability

10K+

Overview Tags

aywengo/kafka-schema-reg-mcp repository overview

⁠Kafka Schema Registry MCP Server

A comprehensive MCP (Model Context Protocol) server that provides Claude 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

🤖 Claude 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

# 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 LLM overhead, run with SLIM_MODE enabled:

# 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 LLM response times

Lower token usage and reduced costs

Ideal for production read-only operations

Simply set SLIM_MODE=true environment variable

⁠Single Registry Mode

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

⁠Multi-Registry Mode

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

⁠🤖 Claude Desktop Integration

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

⁠Single Registry

{
  "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

{
  "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 Claude 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

Variable	Description	Example
`SCHEMA_REGISTRY_URL`	Single registry endpoint	`http://localhost:8081`
`SCHEMA_REGISTRY_NAME_X`	Registry alias (X=1-8)	`production`
`SCHEMA_REGISTRY_URL_X`	Registry endpoint (X=1-8)	`http://prod:8081`
`VIEWONLY_X`	Per-registry viewonly (X=1-8)	`true`
`SCHEMA_REGISTRY_USER_X`	Username (X=1-8)	`user`
`SCHEMA_REGISTRY_PASSWORD_X`	Password (X=1-8)	`pass`

⁠📋 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 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 Claude Desktop to manage your Kafka Schema Registry with natural language! 🚀

Tag summary

Recent tags

Content type

Image

Digest

sha256:83570cba0…

Size

93.9 MB

Last updated

24 days ago

docker pull aywengo/kafka-schema-reg-mcp