Labsco
MCP SERVER

Kafka Schema Drift Auto-Fixer

by rohitdas-ai

Compare two versions of a Kafka schema and see which changes break consumers.

Data Platform: Pipelines, Warehousing, BI & Governance
Summary
Detection only — the fixing is the paid edition.

It answers the question that matters before a deploy: between two versions of a subject, what changed, and which of it breaks downstream consumers. What the name promises beyond that — AST rewriting, regenerated test payloads, automated PRs — belongs to the paid Enterprise edition, not this repository.

What it is

A Python server against a Confluent Schema Registry: it lists the registered subjects and diffs two versions of one, classifying each field change as breaking or backward-compatible. This is the free Community Edition.

What you get
  • Every registered subject in the Schema Registry listed
  • Two versions of a subject diffed — added, removed and modified fields
  • Each change classified as breaking or backward-compatible
  • A drift report naming the fields, their types and their defaults
Requirements

Python, and `pip install -r requirements.txt`; the client runs `python server.py` as a stdio server. The registry URL, API key and API secret are passed as call arguments rather than environment variables, so the credentials travel with each request. Code rewriting, test-payload generation and PR creation are not in this edition.

Setup effort

One command plus a key — pip install -r requirements.txt, then supply credentials