The MCP Kafka Schema Registry Server provides comprehensive tools for managing Kafka Schema Registry instances through a natural language interface. Key capabilities include:
Multi-Registry Management: Configure, test, and manage up to 8 Schema Registry instances simultaneously
Schema Operations: Register, retrieve, update, delete schemas and verify compatibility
Context Management: Create and manage logical groupings of schemas for environment isolation
Migration Tools: Migrate schemas between registries with backup and verification
Export Capabilities: Export schemas, subjects, contexts in JSON or Avro IDL formats
Configuration Management: Update compatibility modes and registry settings
Security Features: OAuth 2.1 authentication, VIEWONLY mode, and scope-based permissions
Monitoring: Track statistics, progress of operations, and async task management
Compliance: Adheres to MCP 2025-06-18 specification
Claude Desktop Integration: Natural language interface for schema management
Packaged as a Docker container for easy deployment and configuration across environments, with various tags for stable and development versions
Mentioned as one of the supported OAuth providers for authentication
Provides Helm charts for simplified deployment to Kubernetes environments
Supported as an OAuth provider for authentication and authorization
Supports deployment to Kubernetes clusters via Helm charts
Supported as an OAuth provider for authentication
Kafka Schema Registry MCP Server
A comprehensive Model Context 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.1.3 | Docker: aywengo/kafka-schema-reg-mcp:stable
๐ Table of Contents
๐ Quick Start
1. Run with Docker (Recommended)
2. Configure Claude Desktop
Copy a ready-to-use configuration from config-examples/
:
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 - 57+ tools following MCP 2025-06-18 specification
๐ SLIM_MODE - Reduce tool overhead from 57+ to ~9 essential tools for better LLM performance
๐ See detailed feature descriptions: docs/api-reference.md
๐ฆ Installation
Option A: Docker (Recommended)
Running with SLIM_MODE
To reduce LLM overhead, run with SLIM_MODE enabled:
๐ก SLIM_MODE Benefits:
Reduces tool count to an essential subset
Significantly faster LLM response times
Lower token usage and reduced costs
Ideal for production read-only operations
Maintains full remote deployment support
Option B: Local Python
Option C: Docker Compose
๐ Detailed installation guide: docs/deployment.md
โ๏ธ Configuration
Single Registry Mode
Multi-Registry Mode (Up to 8 Registries)
Claude Desktop Configuration
Pre-configured examples available in config-examples/
:
Configuration | Use Case | File |
Production | Stable Docker deployment | |
Multi-Environment | DEV/STAGING/PROD registries | |
Local Development | Python local execution | |
View-Only Safety | Production with safety |
๐ Complete configuration guide: config-examples/README.md
SLIM_MODE Configuration (Performance Optimization)
SLIM_MODE reduces the number of exposed MCP tools to an essential subset, significantly reducing LLM overhead and improving response times.
๐ก Recommendation: SLIM_MODE is recommended for most use cases as it provides all essential schema management capabilities with optimal performance.
When to Use SLIM_MODE (Recommended)
Default choice for most users and day-to-day operations
When experiencing slow LLM responses due to too many tools
For production environments focused on read-only operations
When you only need basic schema management capabilities
To reduce token usage and improve performance
When to Use Non-SLIM Mode
For administrators or SRE teams performing long-running operations
When you need advanced operations like:
Schema migrations across registries
Bulk schema removals and cleanup operations
Complex batch operations and workflows
Interactive guided wizards for complex tasks
Comprehensive export/import operations
Enable SLIM_MODE
Tools Available in SLIM_MODE
Essential Read-Only Tools:
ping
- Server health checkset_default_registry
,get_default_registry
- Registry managementcount_contexts
,count_schemas
,count_schema_versions
- Statistics
Basic Write Operations:
register_schema
- Register new schemascheck_compatibility
- Schema compatibility checkingcreate_context
- Create new contexts
Essential Export Operations:
export_schema
- Export single schemaexport_subject
- Export all subject versions
Resources Available (All Modes):
All 19 resources remain available in SLIM_MODE
registry://
,schema://
,subject://
resource URIsFull read access through resource-first approach
Tools Hidden in SLIM_MODE:
All migration tools (
migrate_schema
,migrate_context
)All batch operations (
clear_context_batch
)Advanced export/import tools (
export_context
,export_global
)All interactive/elicitation tools (
*_interactive
variants)Heavy statistics tools with async operations
Task management and workflow tools
Configuration update tools
Delete operations
Note: You can switch between modes by restarting with
SLIM_MODE=false
to access the full tool set.
๐ MCP Tools and Resources
This section provides a comprehensive analysis of all MCP tools and resources exposed by the Kafka Schema Registry MCP Server.
Backward Compatibility Wrapper Tools
These tools are maintained for backward compatibility with existing clients. They internally use efficient implementations but are exposed as tools to prevent "Tool not listed" errors. Consider migrating to the corresponding resources for better performance.
Tool Name | SLIM_MODE | Scope | Recommended Resource | Description |
| โ | read |
| List all configured registries |
| โ | read |
| Get registry information |
| โ | read |
| Test registry connection |
| โ | read |
| Test all registry connections |
| โ | read |
| List all subjects |
| โ | read |
| Get schema content |
| โ | read |
| Get schema versions |
| โ | read |
| Get global configuration |
| โ | read |
| Get registry mode |
| โ | read |
| List all contexts |
| โ | read |
| Get subject configuration |
| โ | read |
| Get subject mode |
Core MCP Tools
Category | Name | Type | SLIM_MODE | Scope | Description |
Core |
| Tool | โ | read | MCP ping/pong health check |
Registry Management |
| Tool | โ | admin | Set default registry |
Registry Management |
| Tool | โ | read | Get current default registry |
Schema Operations |
| Tool | โ | write | Register new schema version |
Schema Operations |
| Tool | โ | read | Check schema compatibility |
Context Management |
| Tool | โ | write | Create new context |
Context Management |
| Tool | โ | admin | Delete context |
Subject Management |
| Tool | โ | admin | Delete subject and versions |
Configuration |
| Tool | โ | admin | Update global configuration |
Configuration |
| Tool | โ | admin | Update subject configuration |
Configuration |
| Tool | โ | write | Create alias subject pointing to an existing subject |
Configuration |
| Tool | โ | write | Remove an alias subject |
Mode Management |
| Tool | โ | admin | Update registry mode |
Mode Management |
| Tool | โ | admin | Update subject mode |
Statistics |
| Tool | โ | read | Count contexts |
Statistics |
| Tool | โ | read | Count schemas |
Statistics |
| Tool | โ | read | Count schema versions |
Statistics |
| Tool | โ | read | Get comprehensive registry stats |
Export |
| Tool | โ | read | Export single schema |
Export |
| Tool | โ | read | Export all subject versions |
Export |
| Tool | โ | read | Export all context subjects |
Export |
| Tool | โ | read | Export all contexts/schemas |
Export |
| Tool | โ | read | Interactive global export |
Migration |
| Tool | โ | admin | Migrate schema between registries |
Migration |
| Tool | โ | admin | Migrate context between registries |
Migration |
| Tool | โ | admin | Interactive context migration |
Migration |
| Tool | โ | read | List migration tasks |
Migration |
| Tool | โ | read | Get migration status |
Comparison |
| Tool | โ | read | Compare two registries |
Comparison |
| Tool | โ | read | Compare contexts across registries |
Comparison |
| Tool | โ | read | Find missing schemas |
Batch Operations |
| Tool | โ | admin | Clear context with batch operations |
Batch Operations |
| Tool | โ | admin | Clear multiple contexts |
Interactive |
| Tool | โ | write | Interactive schema registration |
Interactive |
| Tool | โ | read | Interactive compatibility check |
Interactive |
| Tool | โ | write | Interactive context creation |
Resource Discovery |
| Tool | โ | read | List all available resources |
Resource Discovery |
| Tool | โ | read | Get resource migration suggestions |
Resource Discovery |
| Tool | โ | read | Generate resource URI templates |
Task Management |
| Tool | โ | read | Get task status |
Task Management |
| Tool | โ | read | Get task progress |
Task Management |
| Tool | โ | read | List active tasks |
Task Management |
| Tool | โ | admin | Cancel running task |
Task Management |
| Tool | โ | read | List statistics tasks |
Task Management |
| Tool | โ | read | Get statistics task progress |
Elicitation |
| Tool | โ | write | Submit elicitation response |
Elicitation |
| Tool | โ | read | List elicitation requests |
Elicitation |
| Tool | โ | read | Get elicitation request details |
Elicitation |
| Tool | โ | admin | Cancel elicitation request |
Elicitation |
| Tool | โ | read | Get elicitation system status |
Workflows |
| Tool | โ | read | List available workflows |
Workflows |
| Tool | โ | read | Get workflow status |
Workflows |
| Tool | โ | admin | Start schema migration wizard |
Workflows |
| Tool | โ | admin | Start context reorganization wizard |
Workflows |
| Tool | โ | admin | Start disaster recovery wizard |
Utility |
| Tool | โ | read | Get MCP compliance status |
Utility |
| Tool | โ | read | Get OAuth scopes information |
Utility |
| Tool | โ | read | Test OAuth discovery endpoints |
Utility |
| Tool | โ | read | Get operation metadata |
Utility |
| Tool | โ | read | Check if registry is in viewonly mode |
RESOURCES |
| Resource | โ | read | Overall registry connection status |
RESOURCES |
| Resource | โ | read | Detailed server configuration |
RESOURCES |
| Resource | โ | read | Registry mode detection |
RESOURCES |
| Resource | โ | read | List of configured registry names |
RESOURCES |
| Resource | โ | read | Specific registry connection status |
RESOURCES |
| Resource | โ | read | Specific registry configuration |
RESOURCES |
| Resource | โ | read | Specific registry mode |
RESOURCES |
| Resource | โ | read | List subjects for registry |
RESOURCES |
| Resource | โ | read | List contexts for registry |
RESOURCES |
| Resource | โ | read | Global config for registry |
RESOURCES |
| Resource | โ | read | Schema content with context |
RESOURCES |
| Resource | โ | read | Schema content default context |
RESOURCES |
| Resource | โ | read | Schema versions with context |
RESOURCES |
| Resource | โ | read | Schema versions default context |
RESOURCES |
| Resource | โ | read | Subject config with context |
RESOURCES |
| Resource | โ | read | Subject config default context |
RESOURCES |
| Resource | โ | read | Subject mode with context |
RESOURCES |
| Resource | โ | read | Subject mode default context |
RESOURCES |
| Resource | โ | write | Elicitation response handling |
๐ฌ Usage Examples
Schema Management
Multi-Registry Operations
Batch Operations
๐ More examples: examples/ | ๐ Use cases: docs/use-cases.md
๐ Authentication & Security
OAuth 2.1 Support (Optional)
Supported Providers: Azure AD, Google OAuth, Keycloak, Okta, GitHub
Permission Scopes:
read
- View schemas, configurationswrite
- 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: docs/deployment.md#security
๐ Documentation
Guide | Description |
Complete tool documentation with examples | |
How to add and remove subject aliases | |
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
Examples - Usage examples and code samples
Scripts - Utility scripts and automation
Helm Charts - Kubernetes deployment
Tests - Test suites and validation
๐งช Testing
Quick Test
Docker Testing
MCP Inspector Tests (UI-driven)
๐ Testing guide: TESTING_SETUP_GUIDE.md
๐ Deployment
Production Docker
Kubernetes
๐ Deployment guide: docs/deployment.md
๐ค Contributing
We welcome contributions! Please see:
Quick Development Setup
๐ What's New
v2.1.x (Latest)
๐งญ Subject Aliasing - New tools
add_subject_alias
anddelete_subject_alias
๐ ๏ธ Fixes - Evolution assistant and import interactive fixes
๐ฆ Enhancements - Continued MCP tool refinements and testing improvements
v2.0.x
๐ 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: CHANGELOG.md | ๐ v2.0.0 features: README-v2.0.0-HIGHLIGHTS.md
๐ณ Glama.ai:
๐ณ Docker Hub: aywengo/kafka-schema-reg-mcp
| ๐ Stats: 70+ MCP Tools (12 backward compatibility), 19 Resources, 8 Registries, OAuth 2.1, Multi-platform
License: MIT | Maintainer: @aywengo | Issues: GitHub Issues
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.
Tools
A comprehensive Message Control Protocol (MCP) server for Kafka Schema Registry.
- ๐ Table of Contents
- ๐ Quick Start
- โจ Key Features
- ๐ฆ Installation
- โ๏ธ Configuration
- ๐ MCP Tools and Resources
- ๐ฌ Usage Examples
- ๐ Authentication & Security
- ๐ Documentation
- ๐งช Testing
- ๐ Deployment
- ๐ค Contributing
- ๐ What's New
Related Resources
Related MCP Servers
- -securityAlicense-qualityMCP 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 -34MIT License
- -securityAlicense-qualityMCP 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 -63MIT License
mcp-confluentofficial
AsecurityAlicenseAqualityAn MCP server implementation built to interact with Confluent Kafka and Confluent Cloud REST APIs.Last updated -2428107MIT License- AsecurityAlicenseAqualityAn MCP server that allows searching for and retrieving information about Model Context Protocol servers registered on the MCP Hub.Last updated -11MIT License