kafka-schema-reg-mcp

kafka-schema-reg-mcp

3.4

If you are the rightful owner of kafka-schema-reg-mcp and would like to certify it and/or have it hosted online, please leave a comment on the right or send an email to henry@mcphub.com.

The Kafka Schema Registry MCP Server is a robust Message Control Protocol server designed to facilitate operations with Kafka Schema Registry, offering advanced schema context support and multi-registry management.

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: | Docker: aywengo/kafka-schema-reg-mcp:stable

๐Ÿ“‹ Table of Contents

๐Ÿš€ Quick Start

1. Run with Docker (Recommended)

# 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 :

# 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 - VIEWONLY 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:

๐Ÿ“ฆ Installation

Option A: Docker (Recommended)

# 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.4

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:

โš™๏ธ Configuration

Single Registry Mode

export SCHEMA_REGISTRY_URL="http://localhost:8081"
export SCHEMA_REGISTRY_USER=""           # Optional
export SCHEMA_REGISTRY_PASSWORD=""       # Optional
export VIEWONLY="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 VIEWONLY_1="false"

# Production Registry (with safety)
export SCHEMA_REGISTRY_NAME_2="production"  
export SCHEMA_REGISTRY_URL_2="http://prod-registry:8081"
export VIEWONLY_2="true"                     # Read-only protection

Claude Desktop Configuration

Pre-configured examples available in :

ConfigurationUse CaseFile
ProductionStable Docker deployment
Multi-EnvironmentDEV/STAGING/PROD registries
Local DevelopmentPython local execution
View-Only SafetyProduction with safety

๐Ÿ“– Complete configuration guide:

๐Ÿ’ฌ 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: | ๐Ÿ“– Use cases:

๐Ÿ”’ 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

  • VIEWONLY 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:

๐Ÿ“š Documentation

GuideDescription
Complete tool documentation with examples
Real-world scenarios and implementation patterns
Docker, Kubernetes, cloud platforms, CI/CD
VS Code, Claude Code, Cursor setup
Ready-to-use Claude Desktop configs
Comprehensive testing setup
Version history and migration notes
Major version features

Additional Resources

  • - Usage examples and code samples
  • - Utility scripts and automation
  • - Kubernetes deployment
  • - Test suites and validation

๐Ÿงช 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:

๐Ÿš€ 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:

๐Ÿค 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.x (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
  • ๐Ÿš€ 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: | ๐Ÿ“– v2.0.0 features:


๐Ÿณ Glama.ai:


๐Ÿณ 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