Conduktor

Conduktor MCP

让 AI 助手管理你的 Kafka 环境。

不只是一个连接集群的聊天窗口，而是让 Agent——你的 Agent，或我们的 Agent——了解你运行的每个集群中实际发生的情况，并采取行动：回收没人消费的主题，将成本归属到花费成本的团队，发现下个月即将过期的证书，重启凌晨 3 点故障的连接器，为负责人已离职的主题添加标签。

MCP 端点内置于 Conduktor Console 中。无需部署任何内容，也无需新增安全措施：助手会继承你现有的 RBAC、审计跟踪和所有权模型。

先试用

手边没有 Kafka？demo/ 会通过 docker compose up -d 启动集群、Console 和 MCP 端点，并预先填充主题、流量以及一个故意落后的消费者组。

设置

在 Console 中创建个人访问令牌，然后将 MCP 客户端指向你自己的 Console：

{
  "mcpServers": {
    "conduktor": {
      "command": "npx",
      "args": ["-y", "@conduktor/mcp"],
      "env": {
        "CONDUKTOR_CONSOLE_URL": "https://console.acme-corp.com",
        "CONDUKTOR_API_TOKEN": "your-personal-access-token"
      }
    }
  }
}

系统会自动附加 /api/mcp。粘贴已经以该路径结尾的 URL 也可以。

{
  "mcpServers": {
    "conduktor": {
      "command": "npx",
      "args": [
        "mcp-remote",
        "https://console.acme-corp.com/api/mcp",
        "--header",
        "Authorization: Bearer ${CONDUKTOR_API_TOKEN}"
      ],
      "env": { "CONDUKTOR_API_TOKEN": "your-personal-access-token" }
    }
  }
}

助手可以询问什么

用英语提问，获得基于你实际环境而非文档的答案：

哪些主题已经一个月没有被消费？是谁创建的？ 上个季度支付团队让我们花了多少钱？主要原因是什么？ 这个消费者组卡住了——是什么消息阻塞了它？ 哪些证书会在 3 月之前过期？它们分别属于谁？ 这些主题都没有负责人。能根据数据血缘找出应该由谁负责吗？

这些不是演示。每个问题都对应下面的工具，也对应 Agent 可以无人值守执行的任务。

从回答到运维

同一工具目录服务于两种调用方：你的工具——Claude Code、Cursor、脚本、内部开发者平台——以及在 Console 内运行的 Agent，它们按计划执行，或在审计日志事件触发时执行，并使用各自的机器身份。

第二种方式才是它不再只是聊天机器人的关键。Agent 由任务、身份和一组有界工具构成。它会在周一上午 9 点醒来，或在连接器故障的那一刻醒来，处理问题，然后带回你可以采取行动的结果——报告、建议，或一项由它提出并由你批准的变更。

每次运行都会端到端追踪：提示词、每次工具调用、令牌和结果。你可以将这些信息附加到工单中，或交给审计人员。

工具

共 31 个，涵盖整个控制平面。大多数用于读取；部分用于写入，且写入类工具还在增加。

集群

主题

消息

消费者组

Schema

Connect、Gateway

访问、身份、治理、成本

安全是实现这一切的基础

让 Agent 访问生产环境是合理的，唯一的原因是已有边界，并且每次调用都会强制执行这些边界。

访问权限属于你。 每次调用都会携带 Console 令牌，并以该用户的 RBAC 权限运行。Agent 无法查看其所有者无权查看的集群。撤销所有者的访问权限后，Agent 会同时失去相应权限。

控制平面，而非数据平面。 提供给模型的是元数据——主题、配置、偏移量、消费者组、Schema、数据血缘和成本。除非任务明确需要调用读取记录的工具，否则记录会保留在 Kafka 中。

一切操作均有审计记录。 每次调用都会记入 Console 审计日志，并可追溯到执行调用的身份。

文档

• MCP 服务指南
• 产品页面
• Console 文档

本仓库包含什么

以 @conduktor/mcp 发布的启动器、本文档和注册表元数据。服务本身在 Console 中运行。若服务存在 Bug，请联系 Conduktor 支持；若启动器或本文档存在问题，请在此处提交 issue。