kafka-schema-reg
A comprehensive Message Control Protocol (MCP) server for Kafka Schema Registry.
claude mcp add --transport stdio aywengo-kafka-schema-reg-mcp python kafka_schema_registry_unified_mcp.py \ --env SCHEMA_REGISTRY_URL="http://localhost:8081" \ --env SCHEMA_REGISTRY_USER=""
How to use
This MCP server exposes a Python-based Kafka Schema Registry management toolset via the MCP 2025-06-18 spec. It enables Claude Desktop and other MCP clients to manage multiple Kafka Schema Registry instances, organize contexts for production/staging, migrate schemas across registries, and export schemas in JSON or Avro IDL formats for backup and documentation. Typical workflows include listing contexts, registering or updating schemas, migrating schemas between registries, and exporting registry state for audits. The server integrates with Claude’s MCP tools and supports SLIM_MODE for reduced tool overhead when you don’t need full admin capabilities.
How to install
Prerequisites:
- Python 3.10+ and pip
- Git
- Access to a Kafka Schema Registry instance (or start the included test registry via Docker if desired)
Option A: Install locally (Python)
# 1) Clone the repository
git clone https://github.com/aywengo/kafka-schema-reg-mcp.git
cd kafka-schema-reg-mcp
# 2) Install dependencies
pip install -r requirements.txt
# 3) Run the MCP server (unified Python entrypoint)
python kafka_schema_registry_unified_mcp.py
Option B: Run via Docker (if you prefer containerized deployment)
docker pull aywengo/kafka-schema-reg-mcp:stable
# Example: start with minimal environment for a local registry
docker run -e SCHEMA_REGISTRY_URL=http://localhost:8081 aywengo/kafka-schema-reg-mcp:stable
Option C: Docker Compose (includes a test Schema Registry)
docker-compose up -d
Note: The README indicates a recommended docker-based deployment and a local Python execution path; choose the option that best fits your environment.
Additional notes
Environment variables:
- SCHEMA_REGISTRY_URL: URL of the Kafka Schema Registry instance (e.g., http://localhost:8081)
- SCHEMA_REGISTRY_USER: Optional user for registry authentication
- SLIM_MODE (when using Docker): Enable reduced tool set for faster responses Common issues:
- Ensure the Kafka Schema Registry is reachable at the URL provided by SCHEMA_REGISTRY_URL
- If running locally, expose the registry port and network accordingly
- When using Docker, consider SLIM_MODE for production-readonly workflows to minimize tool overhead Configuration tips:
- Use multiple contexts to isolate production vs. staging registries
- Export formats (JSON, Avro IDL) are useful for backups and documentation
Related MCP Servers
mcp-ssh-orchestrator
Secure SSH access for AI agents via MCP. Execute commands across your server fleet with policy enforcement, network controls, and comprehensive audit logging.
knowledgegraph
MCP server for enabling persistent knowledge storage for Claude through a knowledge graph with multiple storage backends and fuzzy search
mcp -templates
A flexible platform that provides Docker & Kubernetes backends, a lightweight CLI (mcpt), and client utilities for seamless MCP integration. Spin up servers from templates, route requests through a single endpoint with load balancing, and support both deployed (HTTP) and local (stdio) transports — all with sensible defaults and YAML-based configs.
davinci -professional
An enterprise-grade MCP server that exposes the full functionality of DaVinci Resolve and DaVinci Resolve Studio (through version 20) to either Claude Desktop or Cursor MCP clients. Fully configured and tested as a Claude Desktop Extension making installation as easy as clicking a button. Supports both Windows and Macintosh.
mongo
MCP server that provide tools to LLMs such as claude in cursor to interact with MongoDB
mcp-spotify-player
MCP server to manage Spotify from MCP clients