Confluent MCP Server 是一个开源 MCP 服务器，使 AI 助手能够通过自然语言与 Confluent Cloud、Confluent Platform 以及独立 Apache Kafka 部署交互。它提供超过 50 种工具，涵盖 Kafka、Flink SQL、Schema Registry、Connectors、Tableflow 等，可用于任何兼容 MCP 的客户端，包括 Claude Desktop、Claude Code、Cursor、VS Code、Goose 和 Gemini CLI。
用途 Confluent MCP Server 用于把 AI 助手接入 Confluent 生态资源：AI 客户端可通过自然语言调用其提供的工具，与 Confluent Cloud、Confluent Platform 或本地 Kafka / Schema Registry 部署交互。它适合已使用 Confluent Cloud 且希望由 AI 辅助操作资源的场景，也适合需要 Confluent Platform / 自管理 Kafka 支持，或希望自定义和扩展工具集的用户。
主要能力 工具按配置文件中启用的服务块自动启用。始终可用的工具无需服务块或认证，即使配置为空也可用。面向 Confluent Cloud 的工具需要针对特定 Confluent Cloud 组件的端点和认证，部分类别支持 OAuth 认证（通过浏览器登录，而非配置 API 密钥）。面向本地部署的工具仅需 Kafka 或 Schema Registry 端点，不需要 Confluent Cloud API 密钥/密钥对，适合使用自管理集群（含 Confluent Platform）的本地开发。Confluent Cloud 专属工具（如 Flink、Tableflow、Billing、Metrics 等）需要 Confluent Cloud 账户，在 Confluent Platform 上保持禁用。
使用方式 前置条件：Node.js 22.19.0 及以上版本。如需与 Confluent Cloud 交互，需先创建账户。先在项目根目录生成 config.yaml 文件，填入连接信息。启动服务器有两种方式：从源码构建运行（安装依赖 pnpm install，构建项目 pnpm run build 或 pnpm run dev），或直接使用 npx（无需构建）：npx @confluentinc/mcp-confluent --config /path/to/myconfig.yaml。 随后配置 MCP 客户端，使其连接到该服务器所在地址（通常是特定端口的 localhost，端口由 config.yaml 中 server.http.port 设置）。启动 MCP 客户端后，客户端会在启动时于本地运行一个该 MCP 服务器实例，负责管理数据模式并代表用户与资源交互。可通过客户端界面与 Confluent Cloud 或本地资源交互，客户端将请求发送至该 MCP 服务器，由其代为与可用连接交互。
认证与配置 服务器除支持 YAML 配置中定义的静态 API 密钥外，也支持通过 OAuth（PKCE）向 Confluent Cloud 认证：首次需要 Confluent 访问的工具调用时，服务器会打开浏览器跳转 Confluent Cloud 登录页，后续工具调用复用该会话，无需配置 API 密钥。可使用 --init-oauth-config 生成起始配置。YAML（-c config.yaml）与旧版环境变量路径（-e config.env）对单个连接完全兼容；仅环境变量的路径将在未来版本发出启动警告并最终移除。多连接（或无连接）仅支持 YAML。
Tableflow 前提 Tableflow 工具会通过 Confluent Cloud 的 Flink 运行时代表用户与云存储（如 AWS S3）和元数据目录（如 AWS Glue）交互。Flink 运行时需要云账户的 IAM 权限，且必须在任何 Tableflow 工具成功前授予并链接到 Confluent Cloud。跳过此步骤会导致 mcp-confluent 尝试配置或管理 Tableflow 表时出现授权错误。
适用场景 适用于希望通过 AI 助手以自然语言操作 Confluent Cloud、Confluent Platform 或本地 Kafka / Schema Registry 的用户，尤其适合已使用 Confluent Cloud 的客户，以及需要自管理 Kafka 支持或希望自定义扩展工具集的开发者。Confluent Platform 集群的连接方式与任何本地 Kafka + Schema Registry 部署相同，指向 broker 和 Schema Registry 即可；与 localhost:9092 设置的区别仅在认证和 TLS。
限制 该开源 MCP 服务器为社区支持项目，Confluent 不提供专门支持，仅尽力而为，无服务级别承诺。遇到问题或想贡献，可直接在本仓库提交 issue 或 pull request。Node.js 版本需 22.19.0 或以上。工具需要 config.yaml 中特定服务块才会出现；可用 --list-tools 查看激活的工具，或调用 explain-disabled-tools 工具了解单个工具被禁用的原因。HTTP/SSE 认证错误需通过 npx @confluentinc/mcp-confluent --generate-key 生成 API 密钥并添加到 server.auth.api_key。默认 HTTP 端口为 8080，可通过 server.http.port 修改。该服务器会收集使用数据并通过 Sentry 上报服务端运行时错误，可通过设置 DO_NOT_TRACK=true 或 server.do_not_track: true 退出。OAuth 目前仅支持标记的类别，其余仍需静态 API 密钥直连。
