加载中…
Debug Kafka from an agent: find messages, measure consumer lag, unblock consumers, compare clusters.
Kafka MCP 是 ChatHome Skills 收录的 MCP 条目，来源为 Official MCP Registry，质量分 78/100。 作为 Model Context Protocol 服务器，它向 Claude、Cursor、Copilot 等兼容 MCP 的 LLM 客户端暴露可直接调用的工具，让 agent 的能力超出模型内置范围。 该条目由 ChatHome Skills 的每日抓取从官方 registry 和 GitHub 发现查询中收录，每次运行都会重新核验仓库事实、新鲜度信号和安装元数据。 质量分综合了官方 registry 收录情况、可用安装命令、许可证完整性、仓库活跃度和 GitHub star 趋势，完整算法说明见来源页。安装命令已列于上方，可直接复制使用。 在将 Kafka MCP 加入生产 agent 工作流前，请核对上方的最近更新日期和仓库状态——下方事实快照是最近一次抓取的时点值。
docker run -i --rm ghcr.io/denizgursoy/kafka-mcp:v0.2.7运行此命令前，请先核对上游源码。
{
"_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."
}
}