Skip to main content
Glama

MCP Kafka Schema Reg

by aywengo
GitHub
Python
MIT License
14
  • Apple
  • Linux
OverviewInspectNewSchemaRelated ServersReviewsScore
Need Help?View Source CodeReport Issue

Kafka Schema Registry MCP Server

A comprehensive Message Control Protocol (MCP) server that provides Claude Desktop and other MCP clients with tools for Kafka Schema Registry operations. Features advanced schema context support, multi-registry management, and comprehensive schema export capabilities.

🎯 True MCP Implementation: Uses modern FastMCP 2.8.0+ framework with full MCP 2025-06-18 specification compliance. Fully compatible with Claude Desktop and other MCP clients using JSON-RPC over stdio.

Latest Version: v2.0.2 | Docker: aywengo/kafka-schema-reg-mcp:stable

📋 Table of Contents

🚀 Quick Start

# Latest stable release docker pull aywengo/kafka-schema-reg-mcp:stable docker run -e SCHEMA_REGISTRY_URL=http://localhost:8081 aywengo/kafka-schema-reg-mcp:stable

2. Configure Claude Desktop

Copy a ready-to-use configuration from config-examples/:

# macOS cp config-examples/claude_desktop_stable_config.json ~/Library/Application\ Support/Claude/claude_desktop_config.json # Linux cp config-examples/claude_desktop_stable_config.json ~/.config/claude-desktop/config.json

3. Start Using with Claude

Restart Claude Desktop and try these prompts:

  • "List all schema contexts"
  • "Show me the subjects in the production context"
  • "Register a new user schema with fields for id, name, and email"

✨ Key Features

  • 🤖 Claude Desktop Integration - Direct MCP integration with natural language interface
  • 🏢 Multi-Registry Support - Manage up to 8 Schema Registry instances simultaneously
  • 📋 Schema Contexts - Logical grouping for production/staging environment isolation
  • 🔄 Schema Migration - Cross-registry migration with backup and verification
  • 📊 Comprehensive Export - JSON, Avro IDL formats for backup and documentation
  • 🔒 Production Safety - READONLY mode and per-registry access control
  • 🔐 OAuth 2.1 Authentication - Enterprise-grade security with scope-based permissions
  • 📈 Real-time Progress - Async operations with progress tracking and cancellation
  • 🔗 Resource Linking - HATEOAS navigation with enhanced tool responses
  • 🧪 Full MCP Compliance - 48+ tools following MCP 2025-06-18 specification

📖 See detailed feature descriptions: docs/api-reference.md

📦 Installation

# Production stable docker pull aywengo/kafka-schema-reg-mcp:stable # Latest development docker pull aywengo/kafka-schema-reg-mcp:latest # Specific version docker pull aywengo/kafka-schema-reg-mcp:2.0.2

Option B: Local Python

git clone https://github.com/aywengo/kafka-schema-reg-mcp cd kafka-schema-reg-mcp pip install -r requirements.txt python kafka_schema_registry_unified_mcp.py

Option C: Docker Compose

docker-compose up -d # Includes Schema Registry for testing

📖 Detailed installation guide: docs/deployment.md

⚙️ Configuration

Single Registry Mode

export SCHEMA_REGISTRY_URL="http://localhost:8081" export SCHEMA_REGISTRY_USER="" # Optional export SCHEMA_REGISTRY_PASSWORD="" # Optional export READONLY="false" # Production safety

Multi-Registry Mode (Up to 8 Registries)

# Development Registry export SCHEMA_REGISTRY_NAME_1="development" export SCHEMA_REGISTRY_URL_1="http://dev-registry:8081" export READONLY_1="false" # Production Registry (with safety) export SCHEMA_REGISTRY_NAME_2="production" export SCHEMA_REGISTRY_URL_2="http://prod-registry:8081" export READONLY_2="true" # Read-only protection

Claude Desktop Configuration

Pre-configured examples available in config-examples/:

ConfigurationUse CaseFile
ProductionStable Docker deploymentclaude_desktop_stable_config.json
Multi-EnvironmentDEV/STAGING/PROD registriesclaude_desktop_multi_registry_docker.json
Local DevelopmentPython local executionclaude_desktop_config.json
Read-Only SafetyProduction with safetyclaude_desktop_readonly_config.json

📖 Complete configuration guide: config-examples/README.md

💬 Usage Examples

Schema Management

# In Claude Desktop, use natural language: "Register a user schema with id, name, email fields" "Check if my updated schema is compatible" "Export all schemas from staging context" "List subjects in production context"

Multi-Registry Operations

"Compare development and production registries" "Migrate user-events schema from staging to production" "Test connections to all registries" "Show me registry statistics"

Batch Operations

"Clear all schemas from test context" "Export global schemas for backup" "Count schemas across all contexts"

📖 More examples: examples/ | 📖 Use cases: docs/use-cases.md

🔒 Authentication & Security

OAuth 2.1 Support (Optional)

# Enable authentication export ENABLE_AUTH=true export AUTH_ISSUER_URL="https://your-oauth-provider.com" export AUTH_AUDIENCE="your-client-id"

Supported Providers: Azure AD, Google OAuth, Keycloak, Okta, GitHub

Permission Scopes:

  • read - View schemas, configurations
  • write - Register schemas, update configs (includes read)
  • admin - Delete subjects, full control (includes write + read)

Production Safety Features

  • READONLY Mode - Prevent accidental changes in production
  • URL Validation - SSRF protection with configurable localhost access
  • Scope-based Authorization - Fine-grained tool-level permissions
  • Per-Registry Controls - Independent safety settings

📖 Security guide: docs/deployment.md#security

📚 Documentation

GuideDescription
API ReferenceComplete tool documentation with examples
Use CasesReal-world scenarios and implementation patterns
Deployment GuideDocker, Kubernetes, cloud platforms, CI/CD
IDE IntegrationVS Code, Claude Code, Cursor setup
Configuration ExamplesReady-to-use Claude Desktop configs
Testing GuideComprehensive testing setup
ChangelogVersion history and migration notes
v2.0.0 HighlightsMajor version features

Additional Resources

🧪 Testing

Quick Test

cd tests/ ./run_all_tests.sh --quick # Essential tests ./run_all_tests.sh # Complete test suite

Docker Testing

python tests/test_docker_mcp.py

📖 Testing guide: TESTING_SETUP_GUIDE.md

🚀 Deployment

Production Docker

# With docker-compose docker-compose up -d # Direct Docker docker run -d -p 38000:8000 \ -e SCHEMA_REGISTRY_URL=http://registry:8081 \ aywengo/kafka-schema-reg-mcp:stable

Kubernetes

# Using Helm charts helm install kafka-schema-mcp ./helm/kafka-schema-reg-mcp

📖 Deployment guide: docs/deployment.md

🤝 Contributing

We welcome contributions! Please see:

Quick Development Setup

git clone https://github.com/aywengo/kafka-schema-reg-mcp cd kafka-schema-reg-mcp python -m venv .venv && source .venv/bin/activate pip install -r requirements.txt python kafka_schema_registry_unified_mcp.py

🆕 What's New

v2.0.2 (Latest)

  • 🔒 Security Fixes - Resolved credential exposure in logging
  • 🤖 Interactive Schema Migration - Smart migration with user preference elicitation
  • 💾 Automatic Backups - Pre-migration backup creation
  • ✅ Post-Migration Verification - Comprehensive schema validation

v2.0.0 (Major Release)

  • 🚀 FastMCP 2.8.0+ Framework - Complete architecture upgrade
  • 📊 MCP 2025-06-18 Compliance - Latest protocol specification
  • 🔐 OAuth 2.1 Generic Discovery - Universal provider compatibility
  • 🔗 Resource Linking - HATEOAS navigation in tool responses

📖 Full changelog: CHANGELOG.md | 📖 v2.0.0 features: README-v2.0.0-HIGHLIGHTS.md

🐳 Docker Hub: aywengo/kafka-schema-reg-mcp | 📊 Stats: 48+ MCP Tools, 8 Registries, OAuth 2.1, Multi-platform

License: MIT | Maintainer: @aywengo | Issues: GitHub Issues

This server cannot be installed

-
security - not tested
A
license - permissive license
-
quality - not tested

How are these scores calculated?

remote-capable server

The server can be hosted and run remotely because it primarily relies on remote services or has no dependency on the local environment.

A comprehensive Message Control Protocol (MCP) server for Kafka Schema Registry.

  1. 📋 Table of Contents
    1. 🚀 Quick Start
      1. Run with Docker (Recommended)
      2. Configure Claude Desktop
      3. Start Using with Claude
    2. ✨ Key Features
      1. 📦 Installation
        1. Option A: Docker (Recommended)
        2. Option B: Local Python
        3. Option C: Docker Compose
      2. ⚙️ Configuration
        1. Single Registry Mode
        2. Multi-Registry Mode (Up to 8 Registries)
        3. Claude Desktop Configuration
      3. 💬 Usage Examples
        1. Schema Management
        2. Multi-Registry Operations
        3. Batch Operations
      4. 🔒 Authentication & Security
        1. OAuth 2.1 Support (Optional)
        2. Production Safety Features
      5. 📚 Documentation
        1. Additional Resources
      6. 🧪 Testing
        1. Quick Test
        2. Docker Testing
      7. 🚀 Deployment
        1. Production Docker
        2. Kubernetes
      8. 🤝 Contributing
        1. Quick Development Setup
      9. 🆕 What's New
        1. v2.0.2 (Latest)
        2. v2.0.0 (Major Release)

      Related MCP Servers

      • MCP Server

        la-rebelion
        -
        security
        A
        license
        -
        quality
        MCP Server simplifies the implementation of the Model Context Protocol by providing a user-friendly API to create custom tools and manage server workflows efficiently.
        Last updated -
        4
        3
        TypeScript
        MIT License

      • MCP Server

        agentico-dev
        -
        security
        A
        license
        -
        quality
        MCP Server provides a simpler API to interact with the Model Context Protocol by allowing users to define custom tools and services to streamline workflows and processes.
        Last updated -
        13
        2
        TypeScript
        MIT License

      • MCP Maker

        CaptainCrouton89
        -
        security
        -
        license
        -
        quality
        A specialized server that helps users create new Model Context Protocol (MCP) servers by providing tools and templates for scaffolding projects with various capabilities.
        Last updated -
        1
        TypeScript

      • mcp-confluentofficial

        confluentinc
        A
        security
        A
        license
        A
        quality
        An MCP server implementation built to interact with Confluent Kafka and Confluent Cloud REST APIs.
        Last updated -
        24
        116
        69
        TypeScript
        MIT License
        • Apple

      View all related MCP servers

      New MCP Servers

      MCP directory API

      We provide all the information about MCP servers via our MCP API.

      curl -X GET 'https://glama.ai/api/mcp/v1/servers/aywengo/kafka-schema-reg-mcp'

      If you have feedback or need assistance with the MCP directory API, please join our Discord server