Kafka Schema Registry MCP Server

Name: Kafka Schema Registry MCP Server
Author: aywengo

本地服务

github.com/aywengo开发工具32今天更新

代码仓库

关于 Kafka Schema Registry MCP Server

Kafka Schema Registry MCP Server 为 MCP 客户端提供管理 Kafka Schema Registry 数据的工具，支持多个注册表和上下文，并通过 viewer、editor、admin 版本划分可用操作。

主要功能

01管理多个 Schema Registry 实例
02浏览 schema 和上下文
03注册和演进 schema
04比较和迁移注册表
05将 schema 导出为 JSON 或 Avro IDL
06viewer、editor 和 admin 版本

适用场景

01以只读模式浏览生产环境 schema
02在修改 schema 前检查兼容性
03跨环境比较或迁移 schema
04导出注册表 schema 进行备份

MCP 相关

该服务器通过工具、提示词、资源和资源模板向 MCP 客户端开放 Schema Registry 操作。可用工具集由所选的 viewer、editor 或 admin 版本决定。

#kafka #schema-registry #mcp #apache-kafka #mcp-server

配置

本地服务的配置在各客户端中通用，复制后粘贴到客户端的 MCP 配置文件即可。

mcp.json · 通用配置

{
  "mcpServers": {
    "kafka-schema-reg": {
      "command": "docker",
      "args": [
        "run",
        "-i",
        "--rm",
        "-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"
      ],
      "env": {
        "SCHEMA_REGISTRY_NAME_1": "<SCHEMA_REGISTRY_NAME_1>",
        "SCHEMA_REGISTRY_URL_1": "<SCHEMA_REGISTRY_URL_1>",
        "SCHEMA_REGISTRY_USER_1": "<SCHEMA_REGISTRY_USER_1>",
        "SCHEMA_REGISTRY_PASSWORD_1": "<SCHEMA_REGISTRY_PASSWORD_1>",
        "READONLY_1": "<READONLY_1>",
        "SCHEMA_REGISTRY_NAME_2": "<SCHEMA_REGISTRY_NAME_2>",
        "SCHEMA_REGISTRY_URL_2": "<SCHEMA_REGISTRY_URL_2>",
        "SCHEMA_REGISTRY_USER_2": "<SCHEMA_REGISTRY_USER_2>",
        "SCHEMA_REGISTRY_PASSWORD_2": "<SCHEMA_REGISTRY_PASSWORD_2>",
        "READONLY_2": "<READONLY_2>"
      }
    }
  }
}

启动命令

docker run -i --rm -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

需要配置的环境变量

SCHEMA_REGISTRY_NAME_1

SCHEMA_REGISTRY_URL_1

SCHEMA_REGISTRY_USER_1

SCHEMA_REGISTRY_PASSWORD_1密钥

READONLY_1

SCHEMA_REGISTRY_NAME_2

SCHEMA_REGISTRY_URL_2

SCHEMA_REGISTRY_USER_2

SCHEMA_REGISTRY_PASSWORD_2密钥

READONLY_2

本地服务需要在你的电脑上安装运行环境（如 Node.js 18+）。各客户端的配置文件位置不同，请参考客户端文档。

安装包

ociaywengo/kafka-schema-reg-mcp:stablestdio

工具

还没有获取到工具列表

本地服务需要在你的电脑上运行后才能读取工具，维护者暂未提供工具列表。

详细介绍

Kafka Schema Registry MCP 服务

功能全面的 Model Context Protocol（MCP）服务，为 Claude Desktop 和其他 MCP 客户端提供用于 Kafka Schema Registry 操作的工具。支持高级 Schema 上下文、多注册表管理，以及全面的 Schema 导出功能。

🎯 真正的 MCP 实现：基于 MCP Python SDK 2 使用 FastMCP 4.1+，并符合 MCP 2026-07-28 规范。同一进程会与较旧的客户端协商使用 2025-11-25。完全兼容 Claude Desktop 和其他通过 stdio 使用 JSON-RPC 的 MCP 客户端。

最新版本： v3.0.0 | Docker： aywengo/kafka-schema-reg-mcp:stable

🎛️ v3.0 版本。 服务以 viewer（只读：浏览、导出、比较、兼容性）、editor（viewer + Schema 注册和演进）或 admin（完整访问：配置、删除、迁移、批量操作、灾难恢复）模式运行。普通的 :latest / :stable 镜像使用 viewer；-editor 和 -admin 标签以及 Helm 的 edition 值可用于启用更多功能。SLIM_MODE 是已弃用的 editor 别名。参见 docs/editions.md 和 docs/v3-migration-guide.md。

🚀 快速开始

1. 使用 Docker 运行（推荐）

# Latest stable release
docker pull aywengo/kafka-schema-reg-mcp:stable

# Viewer is the default; choose editor or admin explicitly when you need writes
docker run -e MCP_EDITION=editor -e SCHEMA_REGISTRY_URL=http://localhost:8081 aywengo/kafka-schema-reg-mcp:stable

# OR run with the full admin surface for administrators/SRE
docker run -e MCP_EDITION=admin -e SCHEMA_REGISTRY_URL=http://localhost:8081 aywengo/kafka-schema-reg-mcp:stable

2. 配置 Claude Desktop

从 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. 开始使用 Claude

重启 Claude Desktop 并尝试以下提示词：

“列出所有 Schema 上下文”
“向我展示生产环境上下文中的主题”
“注册一个包含 id、name 和 email 字段的新用户 Schema”

✨ 主要功能

🤖 Claude Desktop 集成 - 通过自然语言界面直接集成 MCP
🏢 多注册表支持 - 同时管理最多 8 个 Schema Registry 实例
📋 Schema 上下文 - 逻辑分组，用于隔离生产和暂存环境
🔄 Schema 迁移 - 支持跨注册表迁移，并提供备份和验证
📊 全面导出 - 支持 JSON、Avro IDL 格式，用于备份和文档编制
🔒 生产环境安全 - VIEWONLY 模式和按注册表设置的访问控制
🔐 OAuth 2.1 身份验证 - 企业级安全性，支持基于范围的权限
📈 实时进度 - 支持异步操作，并提供进度跟踪和取消功能
🔗 资源链接 - 通过增强的工具响应实现 HATEOAS 导航
🧪 MCP 2026-07-28 - FastMCP 4 / MCP SDK 2；同一进程也支持 2025-11-25 客户端
🎛️ 三种版本 - 基于同一代码库提供 viewer（39 个工具）、editor（42 个工具）和 admin（66 个工具）

📖 查看详细功能说明：docs/api-reference.md

🛠️ Claude Code 技能

本项目包含 5 个专用 Claude Code 技能——4 个用于自动化 Schema 开发工作流，另有 1 个用于 Schema 上下文比较（/context-compare，详见下文）：

可用技能

/schema-generate - 根据自然语言生成可用于生产环境的 Avro Schema

/schema-generate event UserRegistered "user registration with userId, email, timestamp"

/schema-evolve - 通过自动兼容性检查安全地演进 Schema
```
/schema-evolve user-profile "add optional phoneNumber field"
```
/migration-plan - 创建环境间的详细迁移计划
```
/migration-plan development staging
```

/lint-and-test - 自动化质量保证工作流

/lint-and-test quick        # Before commit (2-3s)
/lint-and-test fix          # Auto-fix issues (20-30s)
/lint-and-test pre-push     # Before push (10-15s)

开始使用技能

**快速入门：**阅读 .claude-code/SKILLS_GUIDE.md - 5 分钟教程

完整参考：.claude-code/skills/README.md - 完整文档

设置摘要：.claude-code/skills/README.md - 配置详情

技能功能

✅ 使用模板通过自然语言生成 Schema
✅ 自动兼容性检查（BACKWARD、FORWARD、FULL）
✅ 提供回滚流程的迁移规划
✅ 提交前和推送前的质量自动化
✅ 与 Black、Ruff、isort、Flake8 集成
✅ 基于 Docker 执行测试
✅ 全面的错误处理和自动修复

立即试用：/schema-generate event TestEvent "test with id and timestamp"

📦 安装

选项 A：Docker（推荐）

# Viewer (default, 39 tools)
docker pull aywengo/kafka-schema-reg-mcp:stable

# Editor (42 tools) and admin (66 tools)
docker pull aywengo/kafka-schema-reg-mcp:stable-editor
docker pull aywengo/kafka-schema-reg-mcp:stable-admin

# Pin the release candidate and edition
docker pull aywengo/kafka-schema-reg-mcp:3.0.0-admin

选择版本

MCP_EDITION 用于在启动时选择工具集。普通标签默认运行 viewer。

# Read-only browsing
docker run -e SCHEMA_REGISTRY_URL=http://localhost:8081 aywengo/kafka-schema-reg-mcp:stable

# Schema registration and evolution
docker run -e MCP_EDITION=editor -e SCHEMA_REGISTRY_URL=http://localhost:8081 aywengo/kafka-schema-reg-mcp:stable

# Full surface, including deletion and migration
docker run -e MCP_EDITION=admin -e SCHEMA_REGISTRY_URL=http://localhost:8081 aywengo/kafka-schema-reg-mcp:stable

**⚠️ SLIM_MODE 已弃用。**它是 MCP_EDITION=editor 的别名，并将在 4.0.0 中移除。请勿同时设置这两个变量。

完整的各版本工具列表请参阅 docs/editions.md，升级路径请参阅 docs/v3-migration-guide.md。

选项 B：本地 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

选项 C：Docker Compose

docker-compose up -d  # Includes Schema Registry for testing

📖 详细安装指南：docs/deployment.md

⚙️ 配置

单注册表模式

export SCHEMA_REGISTRY_URL="http://localhost:8081"
export SCHEMA_REGISTRY_USER=""           # Optional
export SCHEMA_REGISTRY_PASSWORD=""       # Optional
export VIEWONLY="false"                  # Production safety
export MCP_EDITION="viewer"              # viewer | editor | admin (default: viewer)

多注册表模式（最多 8 个注册表）

# 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 配置

config-examples/ 中提供了预配置示例：

配置	使用场景	文件
生产环境	稳定的 Docker 部署	`claude_desktop_stable_config.json`
多环境	DEV/STAGING/PROD 注册表	`claude_desktop_multi_registry_docker.json`
本地开发	Python 本地执行	`claude_desktop_config.json`
只读安全模式	带安全保护的生产环境	`claude_desktop_viewonly_config.json`

📖 完整配置指南：config-examples/README.md

版本配置

版本决定注册哪些工具。当前版本之外的工具不会列出，也无法调用，因此不会占用上下文，也不会被误调用。

版本	工具数	使用场景
`viewer`（默认）	39	浏览、导出、比较、兼容性检查
`editor`	42	Viewer 功能，以及 Schema 注册与演进
`admin`	66	完整功能：配置、删除、迁移、批量操作

export MCP_EDITION="admin"

优先级：MCP_EDITION > SLIM_MODE 别名 > MCP_EDITION_DEFAULT > viewer。同时设置 MCP_EDITION 和 SLIM_MODE 会导致启动错误。

所有版本共享资源。 在 viewer 中仍可通过 registry://、schema:// 和 subject:// 资源进行只读访问。

VIEWONLY 在 HTTP 会话边界强制执行。即使当前版本公开了写入工具，只读注册表也会拒绝 PUT、DELETE 和非读取类 POST 请求。

📊 MCP 工具和资源

工具界面由 tool_catalog.py 生成；docs/editions.md 中的表格也由同一目录生成。

版本	工具数	主要功能
`viewer`	39	注册表信息、主题、Schema、兼容性、导出、比较、统计信息、资源
`editor`	+3	`register_schema`、`check_compatibility`、交互式 Schema 注册
`admin`	+26	配置、删除、上下文、迁移、批量操作、工作流

该服务还公开 10 个提示词、4 个具体资源和 17 个资源模板。参数详情请参阅 docs/mcp-tools-reference.md。

💬 使用示例

Schema 管理

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

多注册表操作

"Compare development and production registries"
"Migrate user-events schema from staging to production"
"Test connections to all registries"
"Show me registry statistics"

批量操作

"Clear all schemas from test context"
"Export global schemas for backup"
"Count schemas across all contexts"

📖 更多示例：examples/ | 📖 使用场景：docs/use-cases.md

🔒 身份验证与安全

OAuth 2.1 支持（可选）

# Enable authentication
export ENABLE_AUTH=true
export AUTH_ISSUER_URL="https://your-oauth-provider.com"
export AUTH_AUDIENCE="your-client-id"

支持的提供商： Azure AD、Google OAuth、Keycloak、Okta、GitHub

权限范围：

read - 查看 Schema 和配置
write - 注册 Schema、更新配置（包括读取权限）
admin - 删除主题、完全控制（包括写入和读取权限）

生产环境安全功能

VIEWONLY 模式 - 防止在生产环境中意外更改
URL 验证 - SSRF 防护，可配置 localhost 访问权限
基于范围的授权 - 精细控制工具级权限
按注册表控制 - 独立的安全设置

📖 安全指南：docs/deployment.md#security

📚 文档

指南	说明
API 参考	完整的工具文档及示例
Subject 别名	如何添加和删除 subject 别名
用例	实际场景和实现模式
部署指南	Docker、Kubernetes、云平台、CI/CD
IDE 集成	VS Code、Claude Code、Cursor 设置
配置示例	可直接使用的 Claude Desktop 配置
测试指南	全面的测试设置
变更日志	版本历史和迁移说明
v2.0.0 亮点	主要版本功能

其他资源

示例 - 用法示例和代码示例
脚本 - 实用脚本和自动化工具
Helm Charts - Kubernetes 部署
测试 - 测试套件和验证

🧪 测试

快速测试

cd tests/
./run_all_tests.sh --quick    # Essential tests
./run_all_tests.sh           # Complete test suite

Docker 测试

python tests/test_docker_mcp.py

MCP Inspector 测试（由 UI 驱动）

# 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_SETUP_GUIDE.md

🚀 部署

生产环境 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

📖 部署指南：docs/deployment.md

🤝 参与贡献

欢迎贡献。请在 GitHub 上提交 issue 或拉取请求，并查看：

快速开发环境设置

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

🆕 最新动态

v3.0.0（最新）

🎛️ 版本 - 从一个镜像提供 viewer（39 个工具）、editor（42 个）和 admin（66 个）；SLIM_MODE 是 editor 的弃用别名
📋 MCP 2026-07-28 - 双时代协议支持，并采用 FastMCP 原生后台任务
🔒 FastMCP 4.1+ - 当前的 MCP SDK 2 技术栈，包含 2026 年安全修复
🧭 MRTR 工作流 - 指导式架构演进、迁移、上下文重组和灾难恢复
🚚 迁移指南 - docs/v3-migration-guide.md

v2.1.x

🧭 Subject 别名 - 新增工具 add_subject_alias 和 delete_subject_alias
🛠️ 修复 - 修复演进助手和交互式导入问题
📦 增强 - 持续改进 MCP 工具和测试
🗑️ 移除弃用工具 - 移除自定义任务管理工具，改用 FastMCP 内置的 Docket 系统

v2.0.x

🔒 安全修复 - 解决日志记录中的凭据暴露问题
🤖 交互式架构迁移 - 根据用户偏好征询结果进行智能迁移
💾 自动备份 - 迁移前创建备份
✅ 迁移后验证 - 全面的架构验证
🚀 FastMCP 2.8.0+ 框架 - 全面升级架构
📊 MCP 2025-06-18 合规性 - v2.0 发布时的协议版本
🔐 OAuth 2.1 通用发现 - 兼容各类提供商
🔗 资源链接 - 在工具响应中提供 HATEOAS 导航

📖 完整变更日志：CHANGELOG.md | 📖 v2.0.0 功能：README-v2.0.0-HIGHLIGHTS.md

🐳 Glama.ai：

🐳 Docker Hub： aywengo/kafka-schema-reg-mcp | 📊 统计： 按版本划分为 39 / 42 / 66 个工具、4 个资源 + 17 个模板、8 个注册表、OAuth 2.1、多平台

许可证： MIT | 维护者： @aywengo | 问题反馈： GitHub Issues

支持 Markdown

登录后评论

第一次接触 MCP？

从协议是什么，到在客户端里装上第一个服务，这几条回答覆盖了大多数入门问题。

阅读入门指南

一个开放协议，规定了 AI 应用如何以统一方式连接外部工具与数据源。客户端负责与模型对话，MCP 服务负责提供工具、资源和提示模板，两者通过标准消息通信，同一个服务可以被不同客户端复用。