Kafka Schema Drift Auto-Fixer
Gateway gratuito de detección de desviaciones y comparación de versiones del Registro de Esquemas de Confluent para el Auto-Fixer AST Empresarial. Se conecta a Confluent, lista los sujetos e identifica campos añadidos, eliminados o modificados.
GitHubPrueba este MCPPatrocinado
Documentación
Kafka Schema Drift Auto-Fixer — Edición Comunitaria
Detección gratuita de desviación de esquemas para Confluent Schema Registry. Para refactorización automatizada de AST, generación de payloads de prueba y creación de PRs, actualice a la edición Enterprise en MCPize →
Qué Hace Esto
Este servidor MCP gratuito se conecta a su Confluent Schema Registry y:
- ✅ Lista todos los sujetos registrados
- ✅ Detecta campos añadidos, eliminados y modificados entre versiones de esquema
- ✅ Clasifica cambios disruptivos vs. retrocompatibles
- ❌ NO reescribe código de consumidores (solo Enterprise)
- ❌ NO genera payloads de prueba (solo Enterprise)
- ❌ NO crea Pull Requests (solo Enterprise)
Instalación
pip install -r requirements.txt
Uso
Ejecutar como servidor MCP stdio
python server.py
Configurar en su cliente MCP (p. ej., Claude Desktop)
{
"mcpServers": {
"kafka-schema-drift-community": {
"command": "python",
"args": ["/path/to/community-edition/server.py"]
}
}
}
Herramientas Disponibles
detect_schema_drift
registry_url: https://your-registry.confluent.cloud
api_key: <your-api-key>
api_secret: <your-api-secret>
subject: payments-value
from_version: 3
to_version: 4
list_subjects
registry_url: https://your-registry.confluent.cloud
api_key: <your-api-key>
api_secret: <your-api-secret>
Ejemplo de Salida
📊 Schema Drift Report: `payments-value` v3 → v4
✅ Added: `correlation_id` (string) [default: '']
🔴 Removed: `legacy_trace_id` (string) — BREAKING
🟠 Modified: `amount` long → double
⚠️ Breaking changes detected across downstream consumer services.
─────────────────────────────────────────────────────────────────
🚀 UPGRADE TO ENTERPRISE
Breaking changes detected. To automatically generate AST refactoring
PRs and rewrite downstream DTOs across all consumer microservices,
upgrade to the Enterprise Kafka Schema Drift Auto-Fixer on MCPize:
👉 https://mcpize.com/mcp/kafka-schema-drift-auto-fixer-mcp
─────────────────────────────────────────────────────────────────
Características Enterprise (Actualice para desbloquear)
| Característica | Comunidad | Enterprise ($49.99/mes) |
|---|---|---|
| Detección de desviación de esquemas | ✅ | ✅ |
| Clasificación de cambios disruptivos | ✅ | ✅ |
| Reescritura de AST políglota (Python/Go/TS) | ❌ | ✅ |
| Inyección de structs con Tree-sitter | ❌ | ✅ |
| Regeneración de payloads de pruebas unitarias | ❌ | ✅ |
| Generación automatizada de PRs | ❌ | ✅ |
| Procesamiento paralelo de subagentes | ❌ | ✅ |
| Firma criptográfica de la cadena de suministro | ❌ | ✅ |
Licencia
MIT — solo Edición Comunitaria. La lógica central de Enterprise es propietaria.