mcp-kafka

Ein Model Context Protocol-Server für Apache Kafka. Er ermöglicht einem MCP-fähigen Client (Claude Desktop, Claude Code, etc.) die Überwachung und Verwaltung von Kafka-Clustern – Topics, Partitionen, Konfigurationen und Consumer-Gruppen (einschließlich Lag) – wobei das Verhalten vollständig über Flags gesteuert wird.

Sicherer Standard: Er startet im Lesemodus, kann auf eine Topic-Allowlist eingeschränkt werden, schützt interne/kritische Topics vor Änderungen und stellt destruktive Operationen nur mit einer ausdrücklichen Zustimmung bereit.

Funktionen

• Monitoring – Cluster-/Broker-Informationen, Topic-Metadaten und Offsets, Consumer-Groups sowie Consumer-Lag pro Partition + gesamt.

• Verwaltung – Erstellen von Topics, Hinzufügen von Partitionen, Ändern von Topic-Konfigurationen, Zurücksetzen von Gruppen-Offsets; Löschen von Topics/Gruppen (Admin).

• Zugriffsmodi – read-only → read-write → admin, so geschichtet, dass ein Modus nie Tools oberhalb seiner Ebene bereitstellt.

• Sicherheits-Flags – Topic-Allowlist, geschützte/interne Topics, Lösch-Gating, Dry-Run und JSON-Audit-Logging (siehe unten).

• Authentifizierung – Klartext, TLS und SASL (PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512).

Related MCP server: Kafka MCP Server

Sicherheitsmodell

Werkzeuge

Lesen (read-only+): cluster_info, list_topics, describe_topic, topic_offsets, list_consumer_groups, describe_consumer_group (mit Lag)

Schreiben (read-write+): create_topic, create_partitions, alter_topic_config, reset_consumer_group_offsets

Admin (admin): delete_topic, delete_consumer_group (beide benötigen KAFKA_ALLOW_DELETE)

Verwendung mit Ihrem MCP-Client

Funktioniert mit Claude Code, Claude Desktop, Cursor, OpenAI Codex CLI, Windsurf, VS Code (Copilot) und jedem anderen MCP-Client – siehe docs/CLIENTS.md für clientspezifische Einrichtung.

Install

npm install
npm run build

Ausführen mit Claude Desktop / Claude Code

{
  "mcpServers": {
    "kafka": {
      "command": "node",
      "args": ["/absolute/path/to/mcp-kafka/dist/index.js"],
      "env": {
        "KAFKA_BROKERS": "broker1:9092,broker2:9092",
        "KAFKA_MODE": "read-only",
        "KAFKA_SSL": "true",
        "KAFKA_SASL_MECHANISM": "scram-sha-512",
        "KAFKA_SASL_USERNAME": "mcp",
        "KAFKA_SASL_PASSWORD": "…"
      }
    }
  }
}

Beispiel-Prompts

• "Welche Consumer-Groups haben derzeit den größten Lag?"

• "Beschreibe das Topic orders und zeige seine Offsets."

• „Erstelle ein Topic events mit 6 Partitionen und 7-tägiger Aufbewahrung.“ (benötigt read-write)

Entwickeln

npm run dev
npm test
npm run typecheck

Veröffentlichung

Dieser Server entählt eine server.json für die offizielle MCP-Registry und einen mcpName zur Bestätigung der npm-Inhaberschaft. Siehe PUBLISHING.md für die Veröffentlichung auf npm und die Auflistung in der MCP-Registry, Smithery, Glama, Cursor und PulseMCP.

Lizenz

MIT