What it does
Debug Apache Kafka: find messages by key or field, measure consumer lag and when it clears, unblock stuck consumers and compare clusters. Read-only endpoints and a preview before every write.
Local connectionPricing not confirmedv0.2.7
Connection manifest
Public connection metadata from the source. Follow the provider’s setup guide for authentication, permissions, and required variables.
{
"name": "io.github.denizgursoy/kafka-mcp",
"version": "0.2.7",
"repository": {
"url": "https://github.com/denizgursoy/kafka-mcp"
},
"remotes": [],
"packages": [
{
"registryType": "oci",
"identifier": "ghcr.io/denizgursoy/kafka-mcp:v0.2.7",
"version": "",
"transport": {
"type": "stdio"
},
"environmentVariables": [
{
"name": "CONFIG_FILE",
"isRequired": false
}
]
},
{
"registryType": "mcpb",
"identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.7/kafka-mcp_0.2.7_darwin_arm64.mcpb",
"version": "0.2.7",
"transport": {
"type": "stdio"
},
"environmentVariables": [
{
"name": "CONFIG_FILE",
"isRequired": true
}
]
},
{
"registryType": "mcpb",
"identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.7/kafka-mcp_0.2.7_linux_amd64.mcpb",
"version": "0.2.7",
"transport": {
"type": "stdio"
},
"environmentVariables": [
{
"name": "CONFIG_FILE",
"isRequired": true
}
]
},
{
"registryType": "mcpb",
"identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.7/kafka-mcp_0.2.7_linux_arm64.mcpb",
"version": "0.2.7",
"transport": {
"type": "stdio"
},
"environmentVariables": [
{
"name": "CONFIG_FILE",
"isRequired": true
}
]
},
{
"registryType": "mcpb",
"identifier": "https://github.com/denizgursoy/kafka-mcp/releases/download/v0.2.7/kafka-mcp_0.2.7_windows_amd64.mcpb",
"version": "0.2.7",
"transport": {
"type": "stdio"
},
"environmentVariables": [
{
"name": "CONFIG_FILE",
"isRequired": true
}
]
}
]
}Metadata reviewed for listing. Server code, permissions, and runtime behavior have not been security-audited. Directory access is free; individual providers may charge.