Kafka Schema Drift Auto-Fixer

Kafka Schema Drift Auto-Fixer — Community Edition

Free schema drift detection for Confluent Schema Registry. For automated AST refactoring, test payload generation, and PR creation, upgrade to the Enterprise edition on MCPize →

---

What This Does

This free MCP server connects to your Confluent Schema Registry and:

• ✅ Lists all registered subjects
• ✅ Detects added, removed, and modified fields between schema versions
• ✅ Classifies breaking vs. backward-compatible changes
• ❌ Does NOT rewrite consumer code (Enterprise only)
• ❌ Does NOT generate test payloads (Enterprise only)
• ❌ Does NOT create Pull Requests (Enterprise only)

---

Install

pip install -r requirements.txt

Usage

Run as stdio MCP server

python server.py

Configure in your MCP client (e.g., Claude Desktop)

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

Available Tools

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>

---

Example Output

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

---

Enterprise Features (Upgrade to unlock)

Feature	Community	Enterprise ($49.99/mo)
Schema drift detection	✅	✅
Breaking change classification	✅	✅
Polyglot AST rewriting (Python/Go/TS)	❌	✅
Tree-sitter struct injection	❌	✅
Unit test payload regeneration	❌	✅
Automated PR generation	❌	✅
Parallel subagent processing	❌	✅
Cryptographic supply chain signing	❌	✅

→ Upgrade on MCPize

---

License

MIT — Community Edition only. Enterprise core-logic is proprietary.