kafka-schema-drift-auto-fixer-free

View on GitHub

Kafka Schema Drift Auto-Fixer

0 stars PythonOthers Updated Jun 19, 2026

Documentation

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

bash

pip install -r requirements.txt

Usage

Run as stdio MCP server

bash

python server.py

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

json

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

Available Tools

`detect_schema_drift`

code

registry_url:  https://your-registry.confluent.cloud
api_key:       
api_secret:    
subject:       payments-value
from_version:  3
to_version:    4

`list_subjects`

code

registry_url:  https://your-registry.confluent.cloud
api_key:       
api_secret:

Example Output

code

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

Frequently asked questions

What is kafka-schema-drift-auto-fixer-free?

kafka-schema-drift-auto-fixer-free is Kafka Schema Drift Auto-Fixer

How do I install kafka-schema-drift-auto-fixer-free?

Open the GitHub repository and follow its README. Most MCP servers are added to your client's MCP config, then called by your agent.

Is kafka-schema-drift-auto-fixer-free open source?

Yes — it is hosted on GitHub at https://github.com/rohitdas-ai/kafka-schema-drift-auto-fixer-free.

Related MCP tools

cognee

Cognee is the open-source AI memory platform for agents. Give your AI agents persistent long-term memory across sessions with a self-hosted knowledge graph engine.

30,433 Python

agent-memoryagent-skillsai+16

skyvern

Automate browser based workflows with AI

22,930 Python

apiautomationbrowser+13

hindsight

Hindsight: Agent Memory That Learns

22,468 Python

agentic-aimemoryagents+1

watermarks-remover

A privacy-first app that strips AI watermarks from content you own.

20,504 Python

agent-skillaic2pa+12

Qwen-Agent

Agent framework and applications built upon Qwen>=3.0, featuring Function Calling, MCP, Code Interpreter, RAG, Chrome extension, etc.

17,062 Python

pal-mcp-server

The power of Claude Code / GeminiCLI / CodexCLI + [Gemini / OpenAI / OpenRouter / Azure / Grok / Ollama / Custom Model / All Of The Above] working as one.

11,731 Python

Run your own MCP server? See who uses it and what to fix.

Measure it with TrackMCP