Kafka Sentinel MCP Server

Name: Kafka Sentinel MCP Server
Author: io.github.sanjay-amu

io.github.sanjay-amu/kafka-sentinel-mcp

Repository Registry

What is the Kafka Sentinel MCP server?

Read-only Kafka observability MCP server: cluster health, consumer lag, and replay-readiness.

How to install Kafka Sentinel

Copy-paste configuration for popular MCP clients.

transport: stdio

Config generated by PluginBench — verify against the source before use.

Environment / auth

KAFKA_BOOTSTRAP
required
Kafka bootstrap servers, e.g. broker1:9092,broker2:9092
KAFKA_SECURITY_PROTOCOL
librdkafka security.protocol, e.g. SASL_SSL
KAFKA_SASL_MECHANISM
librdkafka sasl.mechanism, e.g. PLAIN or SCRAM-SHA-512
KAFKA_SASL_USERNAME
SASL username
KAFKA_SASL_PASSWORD
secret
SASL password
KAFKA_SSL_CA_LOCATION
Path to CA certificate for SSL

Claude Desktop

~/Library/Application Support/Claude/claude_desktop_config.json

{
  "mcpServers": {
    "kafka-sentinel-mcp": {
      "command": "uvx",
      "args": [
        "kafka-sentinel-mcp"
      ],
      "env": {
        "KAFKA_BOOTSTRAP": "<YOUR_KAFKA_BOOTSTRAP>",
        "KAFKA_SECURITY_PROTOCOL": "<YOUR_KAFKA_SECURITY_PROTOCOL>",
        "KAFKA_SASL_MECHANISM": "<YOUR_KAFKA_SASL_MECHANISM>",
        "KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
        "KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>",
        "KAFKA_SSL_CA_LOCATION": "<YOUR_KAFKA_SSL_CA_LOCATION>"
      }
    }
  }
}

Cursor

~/.cursor/mcp.json

{
  "mcpServers": {
    "kafka-sentinel-mcp": {
      "command": "uvx",
      "args": [
        "kafka-sentinel-mcp"
      ],
      "env": {
        "KAFKA_BOOTSTRAP": "<YOUR_KAFKA_BOOTSTRAP>",
        "KAFKA_SECURITY_PROTOCOL": "<YOUR_KAFKA_SECURITY_PROTOCOL>",
        "KAFKA_SASL_MECHANISM": "<YOUR_KAFKA_SASL_MECHANISM>",
        "KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
        "KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>",
        "KAFKA_SSL_CA_LOCATION": "<YOUR_KAFKA_SSL_CA_LOCATION>"
      }
    }
  }
}

Windsurf

~/.codeium/windsurf/mcp_config.json

{
  "mcpServers": {
    "kafka-sentinel-mcp": {
      "command": "uvx",
      "args": [
        "kafka-sentinel-mcp"
      ],
      "env": {
        "KAFKA_BOOTSTRAP": "<YOUR_KAFKA_BOOTSTRAP>",
        "KAFKA_SECURITY_PROTOCOL": "<YOUR_KAFKA_SECURITY_PROTOCOL>",
        "KAFKA_SASL_MECHANISM": "<YOUR_KAFKA_SASL_MECHANISM>",
        "KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
        "KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>",
        "KAFKA_SSL_CA_LOCATION": "<YOUR_KAFKA_SSL_CA_LOCATION>"
      }
    }
  }
}

VS Code

.vscode/mcp.json

{
  "servers": {
    "kafka-sentinel-mcp": {
      "type": "stdio",
      "command": "uvx",
      "args": [
        "kafka-sentinel-mcp"
      ],
      "env": {
        "KAFKA_BOOTSTRAP": "<YOUR_KAFKA_BOOTSTRAP>",
        "KAFKA_SECURITY_PROTOCOL": "<YOUR_KAFKA_SECURITY_PROTOCOL>",
        "KAFKA_SASL_MECHANISM": "<YOUR_KAFKA_SASL_MECHANISM>",
        "KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
        "KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>",
        "KAFKA_SSL_CA_LOCATION": "<YOUR_KAFKA_SSL_CA_LOCATION>"
      }
    }
  }
}

Claude Code

claude mcp add kafka-sentinel-mcp --env KAFKA_BOOTSTRAP=<YOUR_KAFKA_BOOTSTRAP> --env KAFKA_SECURITY_PROTOCOL=<YOUR_KAFKA_SECURITY_PROTOCOL> --env KAFKA_SASL_MECHANISM=<YOUR_KAFKA_SASL_MECHANISM> --env KAFKA_SASL_USERNAME=<YOUR_KAFKA_SASL_USERNAME> --env KAFKA_SASL_PASSWORD=<YOUR_KAFKA_SASL_PASSWORD> --env KAFKA_SSL_CA_LOCATION=<YOUR_KAFKA_SSL_CA_LOCATION> -- uvx kafka-sentinel-mcp