protogrid

Search / io.github.denizgursoy/kafka-mcp

Kafka MCP

L0· runs locally

Debug Kafka from an agent: find messages, measure consumer lag, unblock consumers, compare clusters.

v0.2.3 · active · repository · website · descriptor JSON · versions

Runs on your machine: something must execute the package.Only local packages are published (npm, PyPI, OCI, …). The registry never executes them, so tools are unknown until you run it.
Quality–not scored
Trust94of 100
Packages5
Tools seen0

Connect

8 clients · secrets stay placeholders
{
  "mcpServers": {
    "kafka-mcp": {
      "command": "docker",
      "args": [
        "--mount",
        "type=bind,src=${config_file},dst=/config/kafka-mcp.yaml,readonly",
        "ghcr.io/denizgursoy/kafka-mcp:v0.2.3",
        "--server=false",
        "--endpoint"
      ]
    }
  }
}
claude mcp add kafka-mcp -- docker --mount "type=bind,src=${config_file},dst=/config/kafka-mcp.yaml,readonly" ghcr.io/denizgursoy/kafka-mcp:v0.2.3 --server=false --endpoint
[mcp_servers.kafka-mcp]
command = "docker"
args = ["--mount", "type=bind,src=${config_file},dst=/config/kafka-mcp.yaml,readonly", "ghcr.io/denizgursoy/kafka-mcp:v0.2.3", "--server=false", "--endpoint"]
{
  "$schema": "https://opencode.ai/config.json",
  "mcp": {
    "kafka-mcp": {
      "type": "local",
      "command": [
        "docker",
        "--mount",
        "type=bind,src={env:config_file},dst=/config/kafka-mcp.yaml,readonly",
        "ghcr.io/denizgursoy/kafka-mcp:v0.2.3",
        "--server=false",
        "--endpoint"
      ],
      "enabled": true
    }
  }
}
{
  "mcpServers": {
    "kafka-mcp": {
      "command": "docker",
      "args": [
        "--mount",
        "type=bind,src=${config_file},dst=/config/kafka-mcp.yaml,readonly",
        "ghcr.io/denizgursoy/kafka-mcp:v0.2.3",
        "--server=false",
        "--endpoint"
      ]
    }
  },
  "deeplink": "cursor://anysphere.cursor-deeplink/mcp/install?name=kafka-mcp&config=eyJjb21tYW5kIjoiZG9ja2VyIiwiYXJncyI6WyItLW1vdW50IiwidHlwZT1iaW5kLHNyYz0ke2NvbmZpZ19maWxlfSxkc3Q9L2NvbmZpZy9rYWZrYS1tY3AueWFtbCxyZWFkb25seSIsImdoY3IuaW8vZGVuaXpndXJzb3kva2Fma2EtbWNwOnYwLjIuMyIsIi0tc2VydmVyPWZhbHNlIiwiLS1lbmRwb2ludCJdfQ%3D%3D"
}
{
  "servers": {
    "kafka-mcp": {
      "type": "stdio",
      "command": "docker",
      "args": [
        "--mount",
        "type=bind,src=${config_file},dst=/config/kafka-mcp.yaml,readonly",
        "ghcr.io/denizgursoy/kafka-mcp:v0.2.3",
        "--server=false",
        "--endpoint"
      ]
    }
  }
}
{
  "mcpServers": {
    "kafka-mcp": {
      "command": "docker",
      "args": [
        "--mount",
        "type=bind,src=${config_file},dst=/config/kafka-mcp.yaml,readonly",
        "ghcr.io/denizgursoy/kafka-mcp:v0.2.3",
        "--server=false",
        "--endpoint"
      ]
    }
  }
}
extensions:
  "kafka-mcp":
    enabled: true
    name: "kafka-mcp"
    type: stdio
    cmd: "docker"
    args:
      - "--mount"
      - "type=bind,src=${config_file},dst=/config/kafka-mcp.yaml,readonly"
      - "ghcr.io/denizgursoy/kafka-mcp:v0.2.3"
      - "--server=false"
      - "--endpoint"
    timeout: 300

This is a local package: the command runs on your machine.

Quality – / 100not scored

Not scored: fewer than three checks apply, usually because no remote answered a credential-free probe or the server is a local package.

protocoln/a · weight 25
  • n/a
    protocol.modern, protocol.stateless, protocol.transport, protocol.list_ttlno remote answered a protocol handshake (not probed yet, unreachable, or local-only)
authorizationn/a · weight 15
  • n/a
    auth.prm, auth.as_metadata, auth.cimdno remote uses OAuth
  • n/a
    auth.secret_in_urlno templated URL
tool hygienen/a · weight 30
  • n/a
    tools.descriptions, tools.description_length, tools.schemas, tools.annotations, tools.directory_hints, tools.token_cost, tools.api_dumptool list unknown (behind auth, not probed, or empty)
stabilityn/a · weight 15
  • n/a
    stability.changes, stability.rug_pulltool list unknown
dependenciesn/a · weight 15
  • n/a
    deps.known_vulns, deps.mcp_sdk_version, deps.resolvableno npm or PyPI package

Tool list unknown · checked 2026-10-21 04:51 UTC

Tool changes

No tool definition changes recorded. A server's first observation is its baseline; later probes record what changes.

Checks run on what our credential-free, read-only probes observe; tools are never called and no code audit is performed. How it is computed.

Trust 94 / 100

provenance90
livenessn/a
freshness100
hygiene95

+repository +namespace-matches-repo +website ~liveness-unmeasured +updated-2d-ago -unpinned-packages(1)

Derived from observable signals (official registry feed and our own credential-free probes); no code audit performed. How it is computed.

Endpoints

packageregistryversionruntimesecrets
ghcr.io/denizgursoy/kafka-mcp:v0.2.3ociunpinneddocker
https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_darwin_arm64.mcpbmcpb0.2.3–
https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_linux_amd64.mcpbmcpb0.2.3–
https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_linux_arm64.mcpbmcpb0.2.3–
https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_windows_amd64.mcpbmcpb0.2.3–

Tools (0)

No tools observed. Local packages are never executed by the registry.

Schemas: list_tools.

Similar MCP servers

Official server.json
{
  "name": "io.github.denizgursoy/kafka-mcp",
  "title": "Kafka MCP",
  "$schema": "https://static.modelcontextprotocol.io/schemas/2025-12-11/server.schema.json",
  "version": "0.2.3",
  "packages": [
    {
      "transport": {
        "type": "stdio"
      },
      "identifier": "ghcr.io/denizgursoy/kafka-mcp:v0.2.3",
      "runtimeHint": "docker",
      "registryType": "oci",
      "packageArguments": [
        {
          "type": "positional",
          "value": "--server=false",
          "description": "Serve over stdio instead of the image's default HTTP mode"
        },
        {
          "name": "--endpoint",
          "type": "named",
          "description": "Endpoint from the file to serve. Required when the file defines more than one"
        }
      ],
      "runtimeArguments": [
        {
          "name": "--mount",
          "type": "named",
          "value": "type=bind,src={config_file},dst=/config/kafka-mcp.yaml,readonly",
          "variables": {
            "config_file": {
              "format": "filepath",
              "isRequired": true,
              "description": "Path to your kafka-mcp.yaml: the clusters to connect to and the endpoints to expose"
            }
          },
          "isRequired": true,
          "description": "Mount your kafka-mcp.yaml into the container, read-only"
        }
      ],
      "environmentVariables": [
        {
          "name": "CONFIG_FILE",
          "value": "/config/kafka-mcp.yaml",
          "description": "Where the mounted configuration is read from inside the container"
        }
      ]
    },
    {
      "version": "0.2.3",
      "transport": {
        "type": "stdio"
      },
      "fileSha256": "dae1f9df1b92e926c076b9c214ec4d02ef7c9a9b73f55703c5100b99c27fab4d",
      "identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_darwin_arm64.mcpb",
      "registryType": "mcpb",
      "packageArguments": [
        {
          "name": "--endpoint",
          "type": "named",
          "description": "Which endpoint of the file to serve. Leave empty when the file defines only one."
        }
      ],
      "environmentVariables": [
        {
          "name": "CONFIG_FILE",
          "format": "filepath",
          "isRequired": true,
          "description": "Your kafka-mcp.yaml: the clusters to connect to and the endpoints to expose."
        }
      ]
    },
    {
      "version": "0.2.3",
      "transport": {
        "type": "stdio"
      },
      "fileSha256": "014e9d83473b7af527f888bbd9553e7175629e1aea64d84bb78cf7b7956b4636",
      "identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_linux_amd64.mcpb",
      "registryType": "mcpb",
      "packageArguments": [
        {
          "name": "--endpoint",
          "type": "named",
          "description": "Which endpoint of the file to serve. Leave empty when the file defines only one."
        }
      ],
      "environmentVariables": [
        {
          "name": "CONFIG_FILE",
          "format": "filepath",
          "isRequired": true,
          "description": "Your kafka-mcp.yaml: the clusters to connect to and the endpoints to expose."
        }
      ]
    },
    {
      "version": "0.2.3",
      "transport": {
        "type": "stdio"
      },
      "fileSha256": "0fbaf24e86436162b06a380419232d677bf7dae12de89ed75f90c82f6484bf96",
      "identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_linux_arm64.mcpb",
      "registryType": "mcpb",
      "packageArguments": [
        {
          "name": "--endpoint",
          "type": "named",
          "description": "Which endpoint of the file to serve. Leave empty when the file defines only one."
        }
      ],
      "environmentVariables": [
        {
          "name": "CONFIG_FILE",
          "format": "filepath",
          "isRequired": true,
          "description": "Your kafka-mcp.yaml: the clusters to connect to and the endpoints to expose."
        }
      ]
    },
    {
      "version": "0.2.3",
      "transport": {
        "type": "stdio"
      },
      "fileSha256": "793768c7b52758e85602ecec8250eda029116db010f57eff5b1911b82018e87a",
      "identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_windows_amd64.mcpb",
      "registryType": "mcpb",
      "packageArguments": [
        {
          "name": "--endpoint",
          "type": "named",
          "description": "Which endpoint of the file to serve. Leave empty when the file defines only one."
        }
      ],
      "environmentVariables": [
        {
          "name": "CONFIG_FILE",
          "format": "filepath",
          "isRequired": true,
          "description": "Your kafka-mcp.yaml: the clusters to connect to and the endpoints to expose."
        }
      ]
    }
  ],
  "repository": {
    "id": "1367486735",
    "url": "https://github.com/denizgursoy/kafka-mcp",
    "source": "github"
  },
  "websiteUrl": "https://denizgursoy.github.io/kafka-mcp/",
  "description": "Debug Kafka from an agent: find messages, measure consumer lag, unblock consumers, compare clusters."
}