mcp-kafka

Un servidor de Model Context Protocol para Apache Kafka. Permite a un cliente compatible con MCP (Claude Desktop, Claude Code, etc.) supervisar y administrar clústeres de Kafka — topics, participaciones, configuraciones y grupos de consumidores (incluida la lag) — con un comportamiento controlado enteramente por flags.

Seguro por defecto: se inicia en modo de solo lectura, puede limitarse a una lista de topics permitidos, protege los topics internos/críticos y las particiones de mutaciones, y condiciona las operaciones destructivas a una aceptación explícita.

Características

• Supervisión — información del clúster/broker, offsets de topics y particiones y lag de los grupos de consumidores.

• Gestión — crear topics, añadir particiones, alter la configuración de topics, restablecer offsets de grupos; eliminar topics/grupos (admin).

• Modos de acceso — read-only → read-write → admin, en capas, de modo que un modo nunca expone herramientas por encima de su nivel.

• Flags de seguridad — lista de tools permitidos, topics internal/protegidos, restricción de borrado, dry-run y registro de auditoría en JSON (ver más abajo).

• Autenticación — texto plano, TLS y SASL (PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512).

Related MCP server: Kafka MCP Server

Modelo de seguridad

Herramientas

Lectura (read-only+): cluster_info, list_topics, describe_topic, topic_offsets, list_consumer_groups, describe_consumer_group (con lag)

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

Admin (admin): delete_topic, delete_consumer_group (necesitan KAFKA_ALLOW_DELETE)

Uso con tu cliente MCP

Compatible con Claude Code, Claude Desktop, Cursor, OpenAI Codex CLI, Windsurf, VS Code (Copilot) y cualquier otro cliente MCP — consulta docs/CLIENTS.md para la configuración por cliente.

Instalación

npm install
npm run build

Ejecución con 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": "…"
      }
    }
  }
}

Prompts de ejemplo

• "¿Qué grupos de consumidores tienen más lag en este momento?"

• "Describe el tema orders y muestra sus offsets."

• "Crea un topic events con 6 particiones y 7 días de retención." (requiere read-write)

Desarrollo

npm run dev
npm test
npm run typecheck

Publicación

Este servidor distribuye un server.json para el registro oficial de MCP y un mcpName para la validación de patrocinio en npm. Consulta PUBLISHING.md para publicar en npm y darte de alta en el registro de MCP, Smiterley, Glama, Cursor y PulseMCP.

Licencia

MIT