Kafka Schema Drift Auto-Fixer

Gateway gratuito de detecção de deriva e comparação de versões do Confluent Schema Registry para o Enterprise AST Auto-Fixer. Conecta-se ao Confluent, lista subjects e identifica campos adicionados, removidos ou modificados.

Documentação

Kafka Schema Drift Auto-Fixer — Edição Comunitária

Detecção gratuita de drift de schema para o Confluent Schema Registry. Para refatoração automatizada de AST, geração de payloads de teste e criação de PRs, atualize para a edição Enterprise em MCPize →


O Que Isso Faz

Este servidor MCP gratuito conecta-se ao seu Confluent Schema Registry e:

  • ✅ Lista todos os subjects registrados
  • ✅ Detecta campos adicionados, removidos e modificados entre versões de schema
  • ✅ Classifica mudanças que quebram compatibilidade vs. mudanças retrocompatíveis
  • ❌ NÃO reescreve código de consumidores (somente Enterprise)
  • ❌ NÃO gera payloads de teste (somente Enterprise)
  • ❌ NÃO cria Pull Requests (somente Enterprise)

Instalação

pip install -r requirements.txt

Uso

Executar como servidor MCP stdio

python server.py

Configurar no seu cliente MCP (ex.: Claude Desktop)

{
  "mcpServers": {
    "kafka-schema-drift-community": {
      "command": "python",
      "args": ["/path/to/community-edition/server.py"]
    }
  }
}

Ferramentas Disponíveis

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>

Exemplo de Saída

📊 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
─────────────────────────────────────────────────────────────────

Recursos Enterprise (Atualize para desbloquear)

RecursoComunidadeEnterprise ($49.99/mês)
Detecção de drift de schema✅✅
Classificação de mudanças que quebram compatibilidade✅✅
Reescrita de AST poliglota (Python/Go/TS)❌✅
Injeção de structs com Tree-sitter❌✅
Regeneração de payloads para testes unitários❌✅
Geração automatizada de PRs❌✅
Processamento paralelo com subagentes❌✅
Assinatura criptográfica da cadeia de suprimentos❌✅

→ Atualize no MCPize


Licença

MIT — somente Edição Comunitária. A lógica principal da Enterprise é proprietária.