Not a chat window onto a cluster. A way for agents — yours, or ours — to see what is actually happening across every cluster you run, and to act on it: reclaim the topics nobody consumes, attribute…
kafka-mcp is an MCP project maintained in the conduktor/kafka-mcp repository. The maintainer describes its purpose as “Not a chat window onto a cluster. A way for agents — yours, or ours — to see what is actually happening across every cluster…”. Read the project documentation for the complete scope.
The documented npm package is @conduktor/mcp. The configuration below comes from the maintainer’s example; adapt its paths and account values to your environment.
The example declares CONDUKTOR_CONSOLE_URL, CONDUKTOR_API_TOKEN. Secret-looking values have been replaced with placeholders. Required and optional labels are shown only when the documentation states them.
Project documentation · Repository · Discovery listing. This profile records the public documentation checked on 2026-10-08.
Check the linked publisher documentation and your connected client's tool list. Names and availability can vary with the server version and account permissions.
| Tool | What it does |
|---|---|
| list-clusters | Every Kafka cluster this Console manages, with its Schema Registry, Connect clusters and flavor |
| get-cluster | One cluster's registration by slug |
| insights-cluster | Health score, topic and partition counts, serialization breakdown — the shape of a cluster in one call |
| list-topics | Topic catalogue: names, labels, descriptions, partitions, replication, configs |
| get-topic | One topic by exact name |
| list-topics-with-usage | Topics with message count, size and throughput |
| query-topics | Filter topics across a cluster |
| aggregate-topics | Group topics and compute a statistic per group — count, sum, average, min, max |
| insights-topics | Partition skew, replication problems, and what is quietly wrong |
| get-last-messages | The last N messages from a topic |
| get-record-at | A specific record, by partition and offset — the one blocking a consumer |
| list-consumer-groups | Groups with state, lag and member count |
| get-consumer-group | One group in detail |
| list-consumer-groups-by-topic | Who actually reads this topic |
| get-schema-version | A specific version |
| check-schema-compatibility | Whether a change breaks consumers, before it ships |
| list-interceptors | Gateway interceptors configured on a cluster |
| list-acl-bindings | Who is allowed to do what |
| list-certificates | Certificates and their expiry |
| list-applications | Applications registered in the catalogue |
| get-stream-lineage | What flows into what |
| query-audit-log | Who did what, when |
| get-chargeback-report | Cost attributed per team |
{
"mcpServers": {
"conduktor": {
"command": "npx",
"args": [
"-y",
"@conduktor/mcp"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "https://console.acme-corp.com",
"CONDUKTOR_API_TOKEN": "YOUR_CONDUKTOR_API_TOKEN"
}
}
}
}From the project documentation. Replace placeholders and example paths before connecting.
| Variable | Description | Required |
|---|---|---|
| CONDUKTOR_CONSOLE_URL | Declared in the maintainer’s client configuration. | Check documentation |
| CONDUKTOR_API_TOKEN | Declared in the maintainer’s client configuration. | Check documentation |
Queries the NIST National Vulnerability Database (NVD) via its API.
Scans projects for security vulnerabilities and automatically updates vulnerable dependencies using Trivy.
Search 1,032 verified smart contract vulnerability findings from Sherlock audits by pattern.
Remote MCP for A2A dependency inspector MCP, structured receipts, audit logs, and reviewer-ready evi
Remote MCP for A2A failure replay MCP, structured receipts, audit logs, and reviewer-ready evidence.
A comprehensive Model Context Protocol (MCP) server for ABP.IO framework with 48+ tools for application development, UI generation, and management