Search / io.github.denizgursoy/kafka-mcp
Kafka MCP
L0· runs locallyDebug Kafka from an agent: find messages, measure consumer lag, unblock consumers, compare clusters.
v0.2.3 · active · repository · website · descriptor JSON · versions
Search / io.github.denizgursoy/kafka-mcp
L0· runs locallyDebug Kafka from an agent: find messages, measure consumer lag, unblock consumers, compare clusters.
v0.2.3 · active · repository · website · descriptor JSON · versions
{
"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.
Not scored: fewer than three checks apply, usually because no remote answered a credential-free probe or the server is a local package.
protocol.modern, protocol.stateless, protocol.transport, protocol.list_ttlno remote answered a protocol handshake (not probed yet, unreachable, or local-only)auth.prm, auth.as_metadata, auth.cimdno remote uses OAuthauth.secret_in_urlno templated URLtools.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)stability.changes, stability.rug_pulltool list unknowndeps.known_vulns, deps.mcp_sdk_version, deps.resolvableno npm or PyPI packageNo 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.
+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.
| package | registry | version | runtime | secrets |
|---|---|---|---|---|
ghcr.io/denizgursoy/kafka-mcp:v0.2.3 | oci | unpinned | docker | |
https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_darwin_arm64.mcpb | mcpb | 0.2.3 | – | |
https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_linux_amd64.mcpb | mcpb | 0.2.3 | – | |
https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_linux_arm64.mcpb | mcpb | 0.2.3 | – | |
https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.3/kafka-mcp_0.2.3_windows_amd64.mcpb | mcpb | 0.2.3 | – |
No tools observed. Local packages are never executed by the registry.
Schemas: list_tools.
{
"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."
}