mcp-kafka

Сервер Model Context Protocol для Apache Kafka. Он позволяет MCP-совместимому клиенту (Claude Desktop, Claude Code и т. д.) отслеживать и управлять кластерами Kafka — топиками, партициями, конфигурациями и группами потребителей (включая отставание) — с поведением, полностью управляемым флагами.

Безопасен по умолчанию: запускается в режиме только для чтения, может быть ограничен списком разрешённых топиков, защищает внутренние/критические топики от изменений и закрывает деструктивные операции за явным согласием.

Features

| ...... |

• Мониторинг — информация о кластере/брокерах, метаданные топиков и офсеты, группы потребителей и отставание по каждой партии + общее отставание потребителей.

• Управление — создание топиков, добавление партиций, изменение конфигураций топиков, сброс офсетов группы; удаление топиков/групп (admin).

• Режимы доступа — read-only → read-write → admin, выстроены так, что режим никогда не открывает инструменты выше своего уровня.

• Флаги безопасности — список разрешённых топиков, защищённые/внутренние топики, блокировка удаления, dry-run и запись аудита в JSON (см. ниже).

• Аутентификация — без шифрования, TLS и SASL (PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512).

Related MCP server: Kafka MCP Server

Security model

Tools

Чтение (read-only+): cluster_info, list_topics, describe_topic, topic_offsets, list_consumer_groups, describe_consumer_group (с лагом)

Запись (read-write+): create_topic, create_partitions, alter_topic_config, reset_consumer_group_offsets

Администрирование (admin): delete_topic, delete_consumer_group (оба требуют KAFKA_ALLOW_DELETE)

Использование с MCP-клиентом

Работает с Claude Code, Claude Desktop, Cursor, OpenAI Codex CLI, Windsurf, VS Code (Copilot) и любым другим MCP-клиентом — см. docs/CLIENTS.md для настройки под каждый клиент.

Установка

npm install
npm run build

Запуск с 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": "…"
      }
    }
  }
}

Примеры запросов

• "Какие группы потребителей сейчас имеют наибольшее отставание?"

• "Опиши топик orders и покажи его офсеты."

• "Создай топик events с 6 партициями и хранением в 7 дней." (требуется read-write)

Разработка

npm run dev
npm test
npm run typecheck

Публикация

Сервер содержит server.json для официального реестра MCP и mcpName для проверки владения в npm. См. PUBLISHING.md для публикации в npm и добавлении в свой реестр MCP, Smithery, Glama, Cursor и PulseMCP.

Лицензия

MIT