Skip to main content
Glama

MCP Kafka Schema Reg

MIT License
23
  • Apple
  • Linux

MseeP.ai Security Assessment Badge License: MIT Python Version Docker Pulls GitHub Release GitHub Issues Docker Image Size Maintained MCP Specification Trust Score

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)

# Latest stable release docker pull aywengo/kafka-schema-reg-mcp:stable # Recommended: Run with SLIM_MODE for optimal performance (reduced essential tool set) docker run -e SCHEMA_REGISTRY_URL=http://localhost:8081 -e SLIM_MODE=true aywengo/kafka-schema-reg-mcp:stable # OR run with full feature set for administrators/SRE 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 - 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)

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

Running with SLIM_MODE

To reduce LLM overhead, run with SLIM_MODE enabled:

# Run with a reduced essential tool set docker run -e SCHEMA_REGISTRY_URL=http://localhost:8081 -e SLIM_MODE=true aywengo/kafka-schema-reg-mcp:stable

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

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 VIEWONLY="false" # Production safety export SLIM_MODE="false" # Optional: Enable to reduce tool overhead (default: false)

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 config-examples/:

Configuration

Use Case

File

Production

Stable Docker deployment

claude_desktop_stable_config.json

Multi-Environment

DEV/STAGING/PROD registries

claude_desktop_multi_registry_docker.json

Local Development

Python local execution

claude_desktop_config.json

View-Only Safety

Production with safety

claude_desktop_viewonly_config.json

๐Ÿ“– 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

export SLIM_MODE="true" # Reduces tools from 57+ to ~9 # Enables reduced essential tool set

Tools Available in SLIM_MODE

Essential Read-Only Tools:

  • ping - Server health check

  • set_default_registry, get_default_registry - Registry management

  • count_contexts, count_schemas, count_schema_versions - Statistics

Basic Write Operations:

  • register_schema - Register new schemas

  • check_compatibility - Schema compatibility checking

  • create_context - Create new contexts

Essential Export Operations:

  • export_schema - Export single schema

  • export_subject - Export all subject versions

Resources Available (All Modes):

  • All 19 resources remain available in SLIM_MODE

  • registry://, schema://, subject:// resource URIs

  • Full 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

list_registries

โœ…

read

registry://names

List all configured registries

get_registry_info

โœ…

read

registry://info/{name}

Get registry information

test_registry_connection

โœ…

read

registry://status/{name}

Test registry connection

test_all_registries

โœ…

read

registry://status

Test all registry connections

list_subjects

โœ…

read

registry://{name}/subjects

List all subjects

get_schema

โœ…

read

schema://{name}/{context}/{subject}

Get schema content

get_schema_versions

โœ…

read

schema://{name}/{context}/{subject}/versions

Get schema versions

get_global_config

โœ…

read

registry://{name}/config

Get global configuration

get_mode

โœ…

read

registry://mode

Get registry mode

list_contexts

โœ…

read

registry://{name}/contexts

List all contexts

get_subject_config

โœ…

read

subject://{name}/{context}/{subject}/config

Get subject configuration

get_subject_mode

โœ…

read

subject://{name}/{context}/{subject}/mode

Get subject mode

Core MCP Tools

Category

Name

Type

SLIM_MODE

Scope

Description

Core

ping

Tool

โœ…

read

MCP ping/pong health check

Registry Management

set_default_registry

Tool

โœ…

admin

Set default registry

Registry Management

get_default_registry

Tool

โœ…

read

Get current default registry

Schema Operations

register_schema

Tool

โœ…

write

Register new schema version

Schema Operations

check_compatibility

Tool

โœ…

read

Check schema compatibility

Context Management

create_context

Tool

โœ…

write

Create new context

Context Management

delete_context

Tool

โŒ

admin

Delete context

Subject Management

delete_subject

Tool

โŒ

admin

Delete subject and versions

Configuration

update_global_config

Tool

โŒ

admin

Update global configuration

Configuration

update_subject_config

Tool

โŒ

admin

Update subject configuration

Configuration

add_subject_alias

Tool

โŒ

write

Create alias subject pointing to an existing subject

Configuration

delete_subject_alias

Tool

โŒ

write

Remove an alias subject

Mode Management

update_mode

Tool

โŒ

admin

Update registry mode

Mode Management

update_subject_mode

Tool

โŒ

admin

Update subject mode

Statistics

count_contexts

Tool

โœ…

read

Count contexts

Statistics

count_schemas

Tool

โœ…

read

Count schemas

Statistics

count_schema_versions

Tool

โœ…

read

Count schema versions

Statistics

get_registry_statistics

Tool

โŒ

read

Get comprehensive registry stats

Export

export_schema

Tool

โœ…

read

Export single schema

Export

export_subject

Tool

โœ…

read

Export all subject versions

Export

export_context

Tool

โŒ

read

Export all context subjects

Export

export_global

Tool

โŒ

read

Export all contexts/schemas

Export

export_global_interactive

Tool

โŒ

read

Interactive global export

Migration

migrate_schema

Tool

โŒ

admin

Migrate schema between registries

Migration

migrate_context

Tool

โŒ

admin

Migrate context between registries

Migration

migrate_context_interactive

Tool

โŒ

admin

Interactive context migration

Migration

list_migrations

Tool

โŒ

read

List migration tasks

Migration

get_migration_status

Tool

โŒ

read

Get migration status

Comparison

compare_registries

Tool

โŒ

read

Compare two registries

Comparison

compare_contexts_across_registries

Tool

โŒ

read

Compare contexts across registries

Comparison

find_missing_schemas

Tool

โŒ

read

Find missing schemas

Batch Operations

clear_context_batch

Tool

โŒ

admin

Clear context with batch operations

Batch Operations

clear_multiple_contexts_batch

Tool

โŒ

admin

Clear multiple contexts

Interactive

register_schema_interactive

Tool

โŒ

write

Interactive schema registration

Interactive

check_compatibility_interactive

Tool

โŒ

read

Interactive compatibility check

Interactive

create_context_interactive

Tool

โŒ

write

Interactive context creation

Resource Discovery

list_available_resources

Tool

โœ…

read

List all available resources

Resource Discovery

suggest_resource_for_tool

Tool

โœ…

read

Get resource migration suggestions

Resource Discovery

generate_resource_templates

Tool

โœ…

read

Generate resource URI templates

Task Management

get_task_status

Tool

โŒ

read

Get task status

Task Management

get_task_progress

Tool

โŒ

read

Get task progress

Task Management

list_active_tasks

Tool

โŒ

read

List active tasks

Task Management

cancel_task

Tool

โŒ

admin

Cancel running task

Task Management

list_statistics_tasks

Tool

โŒ

read

List statistics tasks

Task Management

get_statistics_task_progress

Tool

โŒ

read

Get statistics task progress

Elicitation

submit_elicitation_response

Tool

โŒ

write

Submit elicitation response

Elicitation

list_elicitation_requests

Tool

โŒ

read

List elicitation requests

Elicitation

get_elicitation_request

Tool

โŒ

read

Get elicitation request details

Elicitation

cancel_elicitation_request

Tool

โŒ

admin

Cancel elicitation request

Elicitation

get_elicitation_status

Tool

โŒ

read

Get elicitation system status

Workflows

list_available_workflows

Tool

โŒ

read

List available workflows

Workflows

get_workflow_status

Tool

โŒ

read

Get workflow status

Workflows

guided_schema_migration

Tool

โŒ

admin

Start schema migration wizard

Workflows

guided_context_reorganization

Tool

โŒ

admin

Start context reorganization wizard

Workflows

guided_disaster_recovery

Tool

โŒ

admin

Start disaster recovery wizard

Utility

get_mcp_compliance_status_tool

Tool

โŒ

read

Get MCP compliance status

Utility

get_oauth_scopes_info_tool

Tool

โŒ

read

Get OAuth scopes information

Utility

test_oauth_discovery_endpoints

Tool

โŒ

read

Test OAuth discovery endpoints

Utility

get_operation_info_tool

Tool

โŒ

read

Get operation metadata

Utility

check_viewonly_mode

Tool

โŒ

read

Check if registry is in viewonly mode

RESOURCES

registry://status

Resource

โœ…

read

Overall registry connection status

RESOURCES

registry://info

Resource

โœ…

read

Detailed server configuration

RESOURCES

registry://mode

Resource

โœ…

read

Registry mode detection

RESOURCES

registry://names

Resource

โœ…

read

List of configured registry names

RESOURCES

registry://status/{name}

Resource

โœ…

read

Specific registry connection status

RESOURCES

registry://info/{name}

Resource

โœ…

read

Specific registry configuration

RESOURCES

registry://mode/{name}

Resource

โœ…

read

Specific registry mode

RESOURCES

registry://{name}/subjects

Resource

โœ…

read

List subjects for registry

RESOURCES

registry://{name}/contexts

Resource

โœ…

read

List contexts for registry

RESOURCES

registry://{name}/config

Resource

โœ…

read

Global config for registry

RESOURCES

schema://{name}/{context}/{subject}

Resource

โœ…

read

Schema content with context

RESOURCES

schema://{name}/{subject}

Resource

โœ…

read

Schema content default context

RESOURCES

schema://{name}/{context}/{subject}/versions

Resource

โœ…

read

Schema versions with context

RESOURCES

schema://{name}/{subject}/versions

Resource

โœ…

read

Schema versions default context

RESOURCES

subject://{name}/{context}/{subject}/config

Resource

โœ…

read

Subject config with context

RESOURCES

subject://{name}/{subject}/config

Resource

โœ…

read

Subject config default context

RESOURCES

subject://{name}/{context}/{subject}/mode

Resource

โœ…

read

Subject mode with context

RESOURCES

subject://{name}/{subject}/mode

Resource

โœ…

read

Subject mode default context

RESOURCES

elicitation://response/{request_id}

Resource

โŒ

write

Elicitation response handling

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

  • 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

API Reference

Complete tool documentation with examples

Subject Aliasing

How to add and remove subject aliases

Use Cases

Real-world scenarios and implementation patterns

Deployment Guide

Docker, Kubernetes, cloud platforms, CI/CD

IDE Integration

VS Code, Claude Code, Cursor setup

Configuration Examples

Ready-to-use Claude Desktop configs

Testing Guide

Comprehensive testing setup

Changelog

Version history and migration notes

v2.0.0 Highlights

Major 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

MCP Inspector Tests (UI-driven)

# From repository root cd inspector-tests # Single registry (DEV) ./run-inspector-tests.sh stable # Multi-registry (DEV + PROD) ./run-inspector-tests.sh multi # Test a specific Docker tag DOCKER_VERSION=latest ./run-inspector-tests.sh stable

๐Ÿ“– 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.1.x (Latest)

  • ๐Ÿงญ Subject Aliasing - New tools add_subject_alias and delete_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

Deploy Server
A
security โ€“ no known vulnerabilities
A
license - permissive license
A
quality - confirmed to work

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. 1. Run with Docker (Recommended)
      2. 2. Configure Claude Desktop
      3. 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
        4. SLIM_MODE Configuration (Performance Optimization)
      3. ๐Ÿ“Š MCP Tools and Resources
        1. Backward Compatibility Wrapper Tools
        2. Core MCP Tools
      4. ๐Ÿ’ฌ Usage Examples
        1. Schema Management
        2. Multi-Registry Operations
        3. Batch Operations
      5. ๐Ÿ”’ Authentication & Security
        1. OAuth 2.1 Support (Optional)
        2. Production Safety Features
      6. ๐Ÿ“š Documentation
        1. Additional Resources
      7. ๐Ÿงช Testing
        1. Quick Test
        2. Docker Testing
        3. MCP Inspector Tests (UI-driven)
      8. ๐Ÿš€ Deployment
        1. Production Docker
        2. Kubernetes
      9. ๐Ÿค Contributing
        1. Quick Development Setup
      10. ๐Ÿ†• What's New
        1. v2.1.x (Latest)
        2. v2.0.x

      Related MCP Servers

      • -
        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 -
        3
        4
        MIT License
      • -
        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 -
        6
        3
        MIT License
      • A
        security
        A
        license
        A
        quality
        An MCP server implementation built to interact with Confluent Kafka and Confluent Cloud REST APIs.
        Last updated -
        24
        28
        107
        MIT License
        • Apple
      • A
        security
        A
        license
        A
        quality
        An MCP server that allows searching for and retrieving information about Model Context Protocol servers registered on the MCP Hub.
        Last updated -
        1
        1
        MIT License
        • Apple
        • Linux

      View all related 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