](https://mseep.ai/app/aywengo-kafka-schema-reg-mcp) ![License: MIT](https://opensource.org/licenses/MIT) ](https://www.python.org/downloads/) ](https://hub.docker.com/r/aywengo/kafka-schema-reg-mcp) ](https://github.com/aywengo/kafka-schema-reg-mcp/releases) ](https://github.com/aywengo/kafka-schema-reg-mcp/issues) ](https://hub.docker.com/r/aywengo/kafka-schema-reg-mcp) ![Maintained](https://github.com/aywengo/kafka-schema-reg-mcp/graphs/commit-activity) ![MCP Specification](https://modelcontextprotocol.io) ![Trust Score](https://archestra.ai/mcp-catalog/aywengo__kafka-schema-reg-mcp)

Kafka架构注册表MCP服务器

全面 模型上下文协议（MCP）服务器 它为Claude Desktop和其他MCP客户端提供了用于Kafka模式注册表操作的工具。具有高级模式上下文支持、多注册表管理和全面的模式导出功能。

🎯 真正的MCP实施：使用现代 FastMCP 2.8.0+框架 与满 MCP 2025-06-18规范合规性与Claude Desktop和其他使用JSON-RPC的MCP客户端完全兼容 stdio.

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

🚀 快速开始

1.使用Docker运行（推荐）

# 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.配置克劳德桌面

从复制即用配置 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并尝试以下提示：

*“列出所有架构上下文”*
*“向我展示生产环境中的主题”*
*使用id、姓名和电子邮件字段注册新的用户架构*

✨ 主要特点

🤖 Claude桌面集成 -MCP与自然语言接口的直接集成
🏢 多注册表支持 -最多可同时管理8个架构注册表实例
📋 架构上下文 -生产/暂存环境隔离的逻辑分组
🔄 架构迁移 -带备份和验证的跨注册表迁移
📊 综合出口 -用于备份和文档的JSON、Avro IDL格式
🔒 安全生产 -VIEWONLY模式和每个注册表的访问控制
🔐 OAuth 2.1身份验证 -具有基于范围的权限的企业级安全
📈 实时进度 -具有进度跟踪和取消功能的异步操作
🔗 资源链接 -HATEOAS导航，具有增强的工具响应
🧪 完全符合MCP -50多种符合MCP 2025-06-18规范的工具
🚀 SLIM_MODE -将工具开销从50+减少到约9个基本工具，以获得更好的LLM性能

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

🛠️ Claude代码技能

该项目包括 5种专门的Claude代码技能 –4个用于自动化模式开发工作流，1个用于模式上下文比较(/context-compare，记录如下）：

可用技能

/schema-generate -从自然语言生成生产就绪的Avro模式

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

/schema-evolve -通过自动兼容性检查安全地发展模式

  /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 -配置详细信息

技能特点

✅ 使用模板生成自然语言模式
✅ 自动兼容性检查（后退、前进、完全）
✅ 具有回滚程序的迁移规划
✅ 预提交和预推质量自动化
✅ 与Black、Ruff、isort、Flake8融合
✅ 基于Docker的测试执行
✅ 全面的错误处理和自动修复

现在试试： /schema-generate event TestEvent "test with id and timestamp"

📦 安装

选项A:Docker（推荐）

# 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

使用SLIM_MODE运行

要减少LLM开销，请在启用SLIM_MODE的情况下运行：

# 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优点： - 将工具数量减少到一个基本子集 - 显著加快LLM响应时间 - 降低代币使用率和成本 - 非常适合生产只读操作 - 保持完全的远程部署支持

选项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编写

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

多注册表模式（最多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桌面配置

预配置示例可在 config-examples/:

配置	用例	文件
生产	稳定的Docker部署	`claude_desktop_stable_config.json`
多环境	DEV/STAGING/PROD注册表
本地开发	Python本地执行	`claude_desktop_config.json`
仅查看安全	安全生产	`claude_desktop_viewonly_config.json`

📖 完整的配置指南: 配置示例/README.md

SLIM_MODE配置（性能优化）

SLIM_MODE 将暴露的MCP工具的数量减少到一个基本子集，显著降低了LLM开销并缩短了响应时间。

💡 建议： SLIM_MODE是 推荐用于大多数用例 因为它提供了具有最佳性能的所有基本模式管理功能。

何时使用SLIM_MODE（推荐）

默认选择 适用于大多数用户和日常运营
当由于工具太多而遇到LLM响应缓慢时
适用于专注于只读操作的生产环境
当您只需要基本的模式管理功能时
减少令牌使用并提高性能

何时使用非滑动模式

适用于管理员或SRE团队 执行长时间运行的操作
当您需要以下高级操作时：

- 跨注册表的架构迁移 - 批量架构删除和清理操作 - 复杂的批处理操作和工作流 - 用于复杂任务的交互式向导 - 全面的进出口业务

启用SLIM_MODE

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

SLIM_MODE中可用的工具

基本只读工具：

ping -服务器健康检查
set_default_registry, get_default_registry -注册表管理
count_contexts, count_schemas, count_schema_versions -统计数据

基本写入操作：

register_schema -注册新架构
check_compatibility -架构兼容性检查
create_context -创建新上下文

基本出口业务：

export_schema -导出单个架构
export_subject -导出所有主题版本

可用资源（所有模式）：

所有19个资源在SLIM_MODE中仍然可用
registry://, schema://, subject:// 资源URI
通过资源优先的方法实现完全读取权限

隐藏在SLIM_MODE中的工具：

所有迁移工具(migrate_schema, migrate_context)
所有批处理操作(clear_context_batch)
高级导出/导入工具(export_context, export_global)
所有互动/启发工具(*_interactive 变体）
具有异步操作的重型统计工具
工作流工具
配置更新工具
删除操作

注：任务状态跟踪现在由FastMCP的内置Docket系统处理。自定义任务管理工具已被删除，取而代之的是FastMCP的原生任务跟踪。

注：您可以通过重新启动来在模式之间切换 SLIM_MODE=false 访问完整的工具集。

📊 MCP工具和资源

本节对Kafka Schema Registry MCP Server公开的所有MCP工具和资源进行了全面分析。

向后兼容性包装工具

维护这些工具是为了与现有客户端向后兼容。它们在内部使用高效的实现，但作为工具公开，以防止“工具未列出”错误。考虑迁移到相应的资源以获得更好的性能。

工具名称	SLIM_MODE	范围	推荐资源	描述
`list_registries`	✅	阅读	`registry://names`	列出所有已配置的注册表
`get_registry_info`	✅	阅读	`registry://info/{name}`	获取注册表信息
`test_registry_connection`	✅	阅读	`registry://status/{name}`	测试注册表连接
`test_all_registries`	✅	阅读	`registry://status`	测试所有注册表连接
`list_subjects`	✅	阅读	`registry://{name}/subjects`	列出所有主题
`get_schema`	✅	阅读	`schema://{name}/{context}/{subject}`	获取架构内容
`get_schema_versions`	✅	阅读	`schema://{name}/{context}/{subject}/versions`	获取架构版本
`get_global_config`	✅	阅读	`registry://{name}/config`	获取全局配置
`get_mode`	✅	阅读	`registry://mode`	获取注册表模式
`list_contexts`	✅	阅读	`registry://{name}/contexts`	列出所有上下文
`get_subject_config`	✅	阅读	`subject://{name}/{context}/{subject}/config`	获取主题配置
`get_subject_mode`	✅	阅读	`subject://{name}/{context}/{subject}/mode`	获取主题模式

核心MCP工具

类别	名字	类型	SLIM_MODE	范围	描述
核心	`ping`	工具	✅	read	MCP乒乓球健康检查
注册表管理	`set_default_registry`	工具	✅	admin	设置默认注册表
注册表管理	`get_default_registry`	工具	✅	read	获取当前默认注册表
架构操作	`register_schema`	工具	✅	write	注册新的架构版本
架构操作	`check_compatibility`	工具	✅	read	检查架构兼容性
上下文管理	`create_context`	工具	✅	write	创建新上下文
上下文管理	`delete_context`	工具	❌	admin	删除上下文
学科管理	`delete_subject`	工具	❌	admin	删除主题和版本
配置	`update_global_config`	工具	❌	admin	更新全局配置
配置	`update_subject_config`	工具	❌	admin	更新主题配置
配置	`add_subject_alias`	工具	❌	write	创建指向现有主题的别名主题
配置	`delete_subject_alias`	工具	❌	write	删除别名主题
模式管理	`update_mode`	工具	❌	admin	更新注册表模式
模式管理	`update_subject_mode`	工具	❌	admin	更新主题模式
统计	`count_contexts`	工具	✅	read	计数上下文
统计	`count_schemas`	工具	✅	read	计数架构
统计	`count_schema_versions`	工具	✅	read	统计架构版本
统计	`get_registry_statistics`	工具	❌	read	获取全面的注册表统计信息
出口	`export_schema`	工具	✅	read	导出单个架构
出口	`export_subject`	工具	✅	read	导出所有主题版本
出口	`export_context`	工具	❌	read	导出所有上下文主题
出口	`export_global`	工具	❌	read	导出所有上下文/模式
出口	`export_global_interactive`	工具	❌	read	交互式全球导出
迁移	`migrate_schema`	工具	❌	admin	在注册表之间迁移架构
迁移	`migrate_context`	工具	❌	admin	在注册表之间迁移上下文
迁移	`migrate_context_interactive`	工具	❌	admin	交互式上下文迁移
比较	`compare_registries`	工具	❌	read	比较两个注册表
比较	`compare_contexts_across_registries`	工具	❌	read	比较不同注册表的上下文
比较	`find_missing_schemas`	工具	❌	read	查找缺失的架构
批量操作	`clear_context_batch`	工具	❌	admin	清除批处理操作的上下文
批量操作	`clear_multiple_contexts_batch`	工具	❌	admin	清除多个上下文
交互式	`register_schema_interactive`	工具	❌	write	交互式架构注册
交互式	`check_compatibility_interactive`	工具	❌	read	交互式兼容性检查
交互式	`create_context_interactive`	工具	❌	write	交互式上下文创建
资源发现	`list_available_resources`	工具	✅	read	列出所有可用资源
资源发现	`suggest_resource_for_tool`	工具	✅	read	获取资源迁移建议
资源发现	`generate_resource_templates`	工具	✅	read	生成资源URI模板
引出	`submit_elicitation_response`	工具	❌	写	提交启发性回应
引出	`list_elicitation_requests`	工具	❌	read	列出启发请求
引出	`get_elicitation_request`	工具	❌	read	获取启发请求详细信息
引出	`cancel_elicitation_request`	工具	❌	admin	取消启发请求
引出	`get_elicitation_status`	工具	❌	read	获取启发系统状态
工作流	`list_available_workflows`	工具	❌	read	列出可用工作流
工作流	`get_workflow_status`	工具	❌	read	获取工作流状态
工作流	`guided_schema_migration`	工具	❌	admin	启动架构迁移向导
工作流	`guided_context_reorganization`	工具	❌	admin	启动上下文重组向导
工作流	`guided_disaster_recovery`	工具	❌	admin	启动灾难恢复向导
效用	`get_mcp_compliance_status_tool`	工具	❌	read	获取MCP合规状态
效用	`get_oauth_scopes_info_tool`	工具	❌	read	获取OAuth作用域信息
效用	`test_oauth_discovery_endpoints`	工具	❌	read	测试OAuth发现端点
效用	`get_operation_info_tool`	工具	❌	read	获取操作元数据
效用	`check_viewonly_mode`	工具	❌	read	检查注册表是否处于仅查看模式
资源	`registry://status`	资源	✅	read	总体注册表连接状态
资源	`registry://info`	资源	✅	read	详细的服务器配置
资源	`registry://mode`	资源	✅	read	注册表模式检测
资源	`registry://names`	资源	✅	read	已配置的注册表名称列表
资源	`registry://status/{name}`	资源	✅	read	特定注册表连接状态
资源	`registry://info/{name}`	资源	✅	read	特定注册表配置
资源	`registry://mode/{name}`	资源	✅	read	特定注册表模式
资源	`registry://{name}/subjects`	资源	✅	read	列出注册表主题
资源	`registry://{name}/contexts`	资源	✅	read	列出注册表的上下文
资源	`registry://{name}/config`	资源	✅	read	注册表的全局配置
资源	`schema://{name}/{context}/{subject}`	资源	✅	read	带上下文的架构内容
资源	`schema://{name}/{subject}`	资源	✅	read	架构内容默认上下文
资源	`schema://{name}/{context}/{subject}/versions`	资源	✅	read	带上下文的架构版本
资源	`schema://{name}/{subject}/versions`	资源	✅	read	架构版本默认上下文
资源	`subject://{name}/{context}/{subject}/config`	资源	✅	read	带上下文的主题配置
资源	`subject://{name}/{subject}/config`	资源	✅	read	主题配置默认上下文
资源	`subject://{name}/{context}/{subject}/mode`	资源	✅	read	带上下文的主题模式
资源	`subject://{name}/{subject}/mode`	资源	✅	read	主题模式默认上下文
资源	`elicitation://response/{request_id}`	资源	❌	write	诱导反应处理

💬 使用示例

模式管理

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

📖 更多示例: 示例/ | 📖 用例: 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、谷歌OAuth、Keycloak、Okta、GitHub

权限范围：

read -查看架构、配置
write -注册架构，更新配置（包括读取）
admin -删除主题，完全控制（包括写+读）

安全生产特点

查看模式 -防止生产中的意外变化
URL验证 -具有可配置本地主机访问的SSRF保护
基于范围的授权 -细粒度工具级权限
每个注册表控件 -独立安全设置

📖 安全指南: docs/deployment.md#安全

📚 文档

指南	说明
API 参考	完整的工具文档和示例
主题别名	如何添加和删除主题别名
用例	现实世界场景和实施模式
部署指导	Docker、Kubernetes、云平台、CI/CD
IDE集成	VS代码、克劳德代码、游标设置
配置示例	随时可用的Claude桌面配置
测试指导	全面的测试设置
更新日志	版本历史和迁移说明
v2.0.0亮点	主要版本功能

其他资源

例子 -使用示例和代码示例
脚本 -实用程序脚本和自动化
Helm图表 -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检查员测试（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

📖 测试指导: 测试_教程_指南.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

🤝 贡献

我们欢迎捐款！请参阅：

快速开发设置

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

🆕 最新动态

v2.1.x（最新）

🧭 主题别名 -新工具 add_subject_alias 和 delete_subject_alias
🛠️ 修复 -进化助手和导入交互式修复程序
📦 增强 -持续改进MCP工具和测试
🗑️ 已删除弃用的工具 -删除自定义任务管理工具，转而使用FastMCP的内置Docket系统

v2.0.x

🔒 安全修补程序 -解决了日志记录中的凭据暴露问题
🤖 交互式架构迁移 -智能迁移，激发用户偏好
💾 自动备份 -迁移前备份创建
✅ 迁移后验证 -全面的模式验证
🚀 FastMCP 2.8.0+框架 -完成架构升级
📊 MCP 2025-06-18合规性 -最新协议规范
🔐 OAuth 2.1通用发现 -通用提供程序兼容性
🔗 资源链接 -工具响应中的HATEOAS导航

📖 完整更新日志: 更改日志.md | 📖 v2.0.0功能: README-v2.0.0-HIGH LIGHTS.md

______________________________________________________________________

🐳 Glama.ai：