Kafka MCP

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

What does this entry provide?

Kafka MCP is an MCP server entry in ChatHome Skills, sourced from Official MCP Registry and scored 78/100. As a Model Context Protocol server, it exposes tools that MCP-compatible LLM clients such as Claude, Cursor, and Copilot can call directly, extending an agent's reach beyond its built-in capabilities. ChatHome Skills discovered this entry through its daily ingest of official registries and GitHub discovery queries, and re-verifies repository facts, freshness signals, and install metadata on every run. The quality score weighs official-registry presence, a working install command, license clarity, GitHub star trajectory, and repository freshness — the full formula is on the Sources page. The install command above is ready to copy. Review the last-pushed date and repository status before adding Kafka MCP to a production agent workflow; the snapshot facts below are point-in-time values from the most recent ingest.

Snapshot facts

Source: Official MCP Registry
Quality: 78/100
Install method: oci
Repo: denizgursoy/kafka-mcp
Repo updated: Oct 23, 2026

Install command

docker run -i --rm ghcr.io/denizgursoy/kafka-mcp:v0.2.7

Install method: oci

Review the upstream source before running this command.

GitHub project Homepage

Quality

Repo stars

Repo updated

Oct 23, 2026

How is this score calculated?

Weighted across six dimensions, scored 0-100.
Provenance (25): listed in an official or curated registry.
Installability (25): a runnable install command beats a declared transport, which beats a source checkout.
Maintenance (20): recency of the last push; archived entries score zero here.
Adoption (20): repository stars on a log curve.
Documentation (10) and description quality (10): parsed manifest or SKILL.md frontmatter, and a real description rather than a placeholder.

MCP manifest

{
  "_meta": {
    "io.modelcontextprotocol.registry/official": {
      "status": "active",
      "isLatest": true,
      "updatedAt": "2026-10-23T13:12:43.468703Z",
      "publishedAt": "2026-10-23T13:12:43.468703Z",
      "statusChangedAt": "2026-10-23T13:12:43.468703Z"
    }
  },
  "server": {
    "name": "io.github.denizgursoy/kafka-mcp",
    "title": "Kafka MCP",
    "$schema": "https://static.modelcontextprotocol.io/schemas/2025-12-11/server.schema.json",
    "version": "0.2.7",
    "packages": [
      {
        "transport": {
          "type": "stdio"
        },
        "identifier": "ghcr.io/denizgursoy/kafka-mcp:v0.2.7",
        "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.7",
        "transport": {
          "type": "stdio"
        },
        "fileSha256": "a6fd772fece4c76ff35ed22862641cefe0b52f52d247ce93f30fbb46b118beba",
        "identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.7/kafka-mcp_0.2.7_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.7",
        "transport": {
          "type": "stdio"
        },
        "fileSha256": "8d86b838ff1b26229de75108647e3c1942060f98b0abda09566184f8cdfbbe97",
        "identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.7/kafka-mcp_0.2.7_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.7",
        "transport": {
          "type": "stdio"
        },
        "fileSha256": "9622d866c21c6d722ad785a9020d30da7e8a05e1cbb302a55d228d7a70323b9b",
        "identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.7/kafka-mcp_0.2.7_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.7",
        "transport": {
          "type": "stdio"
        },
        "fileSha256": "b5a8ac227755b9f892fec719585c8137dc08db7f0baffeb3e3e53d432f9e16ff",
        "identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.7/kafka-mcp_0.2.7_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."
  }
}

Report an issue with this listing