# 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 →](https://mcpize.com/mcp/kafka-schema-drift-auto-fixer-mcp)

---

## 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`
```
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](https://mcpize.com/mcp/kafka-schema-drift-auto-fixer-mcp)**

---

## License

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