Kafka Schema Drift Auto-Fixer

from rohitdas-ai

Free Confluent Schema Registry drift detector and version comparison gateway for the Enterprise AST Auto-Fixer. Connects to Confluent, lists subjects, and identifies added, removed, or modified fields.

🔥🔥✓ VerifiedFreeQuick setup

#automation #payments #finance

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)

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

Copy & paste — that's it

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

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>

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