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.
GitHubExperimente este MCPPatrocinado
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)
| Recurso | Comunidade | Enterprise ($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 | ❌ | ✅ |
Licença
MIT — somente Edição Comunitária. A lógica principal da Enterprise é proprietária.