Search / io.github.conduktor/kafka-mcp
Conduktor
L0· runs locallyRead-only Kafka access for AI assistants: topics, consumer groups, schemas, cluster health.
v1.0.1 · active · repository · website · descriptor JSON · versions
Search / io.github.conduktor/kafka-mcp
L0· runs locallyRead-only Kafka access for AI assistants: topics, consumer groups, schemas, cluster health.
v1.0.1 · active · repository · website · descriptor JSON · versions
{
"mcpServers": {
"kafka-mcp": {
"command": "npx",
"args": [
"-y",
"@conduktor/[email protected]"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "${CONDUKTOR_CONSOLE_URL}",
"CONDUKTOR_API_TOKEN": "${CONDUKTOR_API_TOKEN}"
}
}
}
}claude mcp add kafka-mcp -e "CONDUKTOR_CONSOLE_URL=${CONDUKTOR_CONSOLE_URL}" -e "CONDUKTOR_API_TOKEN=${CONDUKTOR_API_TOKEN}" -- npx -y @conduktor/[email protected][mcp_servers.kafka-mcp]
command = "npx"
args = ["-y", "@conduktor/[email protected]"]
env = { "CONDUKTOR_CONSOLE_URL" = "${CONDUKTOR_CONSOLE_URL}", "CONDUKTOR_API_TOKEN" = "${CONDUKTOR_API_TOKEN}" }
{
"$schema": "https://opencode.ai/config.json",
"mcp": {
"kafka-mcp": {
"type": "local",
"command": [
"npx",
"-y",
"@conduktor/[email protected]"
],
"enabled": true,
"environment": {
"CONDUKTOR_CONSOLE_URL": "{env:CONDUKTOR_CONSOLE_URL}",
"CONDUKTOR_API_TOKEN": "{env:CONDUKTOR_API_TOKEN}"
}
}
}
}{
"mcpServers": {
"kafka-mcp": {
"command": "npx",
"args": [
"-y",
"@conduktor/[email protected]"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "${CONDUKTOR_CONSOLE_URL}",
"CONDUKTOR_API_TOKEN": "${CONDUKTOR_API_TOKEN}"
}
}
},
"deeplink": "cursor://anysphere.cursor-deeplink/mcp/install?name=kafka-mcp&config=eyJjb21tYW5kIjoibnB4IiwiYXJncyI6WyIteSIsIkBjb25kdWt0b3IvbWNwQDEuMC4wIl0sImVudiI6eyJDT05EVUtUT1JfQ09OU09MRV9VUkwiOiIke0NPTkRVS1RPUl9DT05TT0xFX1VSTH0iLCJDT05EVUtUT1JfQVBJX1RPS0VOIjoiJHtDT05EVUtUT1JfQVBJX1RPS0VOfSJ9fQ%3D%3D"
}{
"servers": {
"kafka-mcp": {
"type": "stdio",
"command": "npx",
"args": [
"-y",
"@conduktor/[email protected]"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "${CONDUKTOR_CONSOLE_URL}",
"CONDUKTOR_API_TOKEN": "${CONDUKTOR_API_TOKEN}"
}
}
}
}{
"mcpServers": {
"kafka-mcp": {
"command": "npx",
"args": [
"-y",
"@conduktor/[email protected]"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "${CONDUKTOR_CONSOLE_URL}",
"CONDUKTOR_API_TOKEN": "${CONDUKTOR_API_TOKEN}"
}
}
}
}extensions:
"kafka-mcp":
enabled: true
name: "kafka-mcp"
type: stdio
cmd: "npx"
args:
- "-y"
- "@conduktor/[email protected]"
envs:
"CONDUKTOR_CONSOLE_URL": "${CONDUKTOR_CONSOLE_URL}"
"CONDUKTOR_API_TOKEN": "${CONDUKTOR_API_TOKEN}"
timeout: 300
Placeholders to fill from your own secret store: ${CONDUKTOR_API_TOKEN}. The registry never accepts secret values.
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_urlURL variables carry no secrettools.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.resolvabledeps.dev does not know @conduktor/[email protected]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.
+repository +namespace-matches-repo +website ~liveness-unmeasured +updated-14d-ago
Derived from observable signals (official registry feed and our own credential-free probes); no code audit performed. How it is computed.
@conduktor/[email protected] npmthis version is not known to the dependency resolver
Dependency graphs from deps.dev; advisories from OSV.dev, including the GitHub Advisory Database and the PyPI Advisory Database; all CC BY 4.0. The graph is what a clean install of this version resolves today; nothing was installed or run. How it is checked.
| remote | auth | reachable | uptime 30d | p50 | protocol | last ok |
|---|---|---|---|---|---|---|
https://{console_host}/api/mcp streamable-http · templated | unknown | not probed | – | – | – | – |
| package | registry | version | runtime | secrets |
|---|---|---|---|---|
@conduktor/mcp | npm | 1.0.0 | – | CONDUKTOR_API_TOKEN |
No tools observed. Local packages are never executed by the registry.
Schemas: list_tools.
{
"name": "io.github.conduktor/kafka-mcp",
"title": "Conduktor",
"$schema": "https://static.modelcontextprotocol.io/schemas/2025-12-11/server.schema.json",
"remotes": [
{
"url": "https://{console_host}/api/mcp",
"type": "streamable-http",
"headers": [
{
"name": "Authorization",
"value": "Bearer {token}",
"variables": {
"token": {
"format": "string",
"isSecret": true,
"isRequired": true,
"description": "Personal Access Token created in Conduktor Console"
}
},
"isRequired": true
}
],
"variables": {
"console_host": {
"format": "string",
"isRequired": true,
"description": "Your Conduktor Console hostname, e.g. console.acme-corp.com"
}
}
}
],
"version": "1.0.1",
"packages": [
{
"version": "1.0.0",
"transport": {
"type": "stdio"
},
"identifier": "@conduktor/mcp",
"registryType": "npm",
"environmentVariables": [
{
"name": "CONDUKTOR_CONSOLE_URL",
"format": "string",
"isRequired": true,
"description": "Your Conduktor Console base URL, e.g. https://console.acme-corp.com"
},
{
"name": "CONDUKTOR_API_TOKEN",
"format": "string",
"isSecret": true,
"isRequired": true,
"description": "Personal Access Token created in Conduktor Console"
}
]
}
],
"repository": {
"url": "https://github.com/conduktor/kafka-mcp",
"source": "github"
},
"websiteUrl": "https://www.conduktor.io/mcp",
"description": "Read-only Kafka access for AI assistants: topics, consumer groups, schemas, cluster health."
}