Kafka Schema Registry MCP Server

by aywengo

32 stars
385 downloads
Not rated
GitHub

About

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

Details

Author
aywengo
GitHub stars
32
Downloads
385
Categories
Developer Tools, Other

- Multi-registry management (up to 8 registries)
- Schema contexts for environment isolation
- Schema migration with backup and verification
- Comprehensive export in JSON and Avro IDL formats
- Production safety with VIEWONLY mode
- OAuth 2.1 authentication support

Setting up with Highlight

This MCP is not yet compatible with Highlight’s one-click setup. However, you can still use it with Highlight by following these steps:

  1. Download and install Highlight from highlightai.com/download
  2. Navigate to the plugins tab and select "Add Custom Plugin"
  3. Configure the plugin with the settings below
    Plugin Name Kafka Schema Registry MCP Server
    Command (node, npx, python, etc.)

    Please refer to the README for specific instructions on how to obtain API keys or other required environment variables.

  4. Enable "Start Automatically" if you want the plugin to start when Highlight launches

From the repository

Install via Docker (recommended) with environment variables for registry URL, then configure Claude Desktop using the provided config examples. Interact using natural language prompts to list contexts, register schemas, or export schemas. Alternatively, run locally with Python or use Docker Compose for testing.

Claude Desktop / Cursor

Paste into your MCP client config file to install this server.

{
    "mcpServers": {
        "kafka schema registry mcp server": {
            "kafka-schema-registry-multi": {
                "command": "docker",
                "args": [
                    "run",
                    "--rm",
                    "-i",
                    "--network",
                    "host",
                    "-e",
                    "SCHEMA_REGISTRY_NAME_1",
                    "-e",
                    "SCHEMA_REGISTRY_URL_1",
                    "-e",
                    "SCHEMA_REGISTRY_USER_1",
                    "-e",
                    "SCHEMA_REGISTRY_PASSWORD_1",
                    "-e",
                    "READONLY_1",
                    "-e",
                    "SCHEMA_REGISTRY_NAME_2",
                    "-e",
                    "SCHEMA_REGISTRY_URL_2",
                    "-e",
                    "SCHEMA_REGISTRY_USER_2",
                    "-e",
                    "SCHEMA_REGISTRY_PASSWORD_2",
                    "-e",
                    "READONLY_2",
                    "aywengo/kafka-schema-reg-mcp:stable",
                    "python",
                    "kafka_schema_registry_unified_mcp.py"
                ],
                "env": {
                    "SCHEMA_REGISTRY_NAME_1": "<NAME of SR 1>",
                    "SCHEMA_REGISTRY_URL_1": "<URL of SR  1>",
                    "SCHEMA_REGISTRY_USER_1": "",
                    "SCHEMA_REGISTRY_PASSWORD_1": "",
                    "READONLY_1": "false",
                    "SCHEMA_REGISTRY_NAME_2": "<NAME of SR 2>",
                    "SCHEMA_REGISTRY_URL_2": "<URL of SR 2>",
                    "SCHEMA_REGISTRY_USER_2": "",
                    "SCHEMA_REGISTRY_PASSWORD_2": "",
                    "READONLY_2": "false"
                }
            }
        }
    }
}

McpServers

{
    "kafka-schema-registry-multi": {
        "command": "docker",
        "args": [
            "run",
            "--rm",
            "-i",
            "--network",
            "host",
            "-e",
            "SCHEMA_REGISTRY_NAME_1",
            "-e",
            "SCHEMA_REGISTRY_URL_1",
            "-e",
            "SCHEMA_REGISTRY_USER_1",
            "-e",
            "SCHEMA_REGISTRY_PASSWORD_1",
            "-e",
            "READONLY_1",
            "-e",
            "SCHEMA_REGISTRY_NAME_2",
            "-e",
            "SCHEMA_REGISTRY_URL_2",
            "-e",
            "SCHEMA_REGISTRY_USER_2",
            "-e",
            "SCHEMA_REGISTRY_PASSWORD_2",
            "-e",
            "READONLY_2",
            "aywengo/kafka-schema-reg-mcp:stable",
            "python",
            "kafka_schema_registry_unified_mcp.py"
        ],
        "env": {
            "SCHEMA_REGISTRY_NAME_1": "<NAME of SR 1>",
            "SCHEMA_REGISTRY_URL_1": "<URL of SR  1>",
            "SCHEMA_REGISTRY_USER_1": "",
            "SCHEMA_REGISTRY_PASSWORD_1": "",
            "READONLY_1": "false",
            "SCHEMA_REGISTRY_NAME_2": "<NAME of SR 2>",
            "SCHEMA_REGISTRY_URL_2": "<URL of SR 2>",
            "SCHEMA_REGISTRY_USER_2": "",
            "SCHEMA_REGISTRY_PASSWORD_2": "",
            "READONLY_2": "false"
        }
    }
}

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.

<table width="100%">
<tr>
<td width="33%" style="vertical-align: top;">
<div style="background-color: white; padding: 20px; border-radius: 10px;">
Kafka Schema Registry MCP Logo
</div>
</td>
<td width="67%" style="vertical-align: top; padding-left: 20px;">

> 🎯 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.5 | Docker: aywengo/kafka-schema-reg-mcp:stable
</td>
</tr>
</table>

πŸ“‹ Table of Contents

- πŸš€ Quick Start
- ✨ Key Features
- πŸ› οΈ Claude Code Skills
- πŸ“¦ Installation
- βš™οΈ Configuration
- πŸ’¬ Usage Examples
- πŸ”’ Authentication & Security
- πŸ“š Documentation
- πŸ§ͺ Testing
- πŸš€ Deployment
- 🀝 Contributing
- πŸ†• What's New

πŸš€ Quick Start

1. Run with Docker (Recommended)

```bash
No reviews yet β€” be the first

Sign in to leave a review

Use Google, GitHub, or an email account so ratings stay tied to real people.

Email sign in

No reviews posted yet.