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.

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ísticaComunidadEnterprise ($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❌✅

→ Actualice en MCPize


Licencia

MIT — solo Edición Comunitaria. La lógica central de Enterprise es propietaria.