mcp-confluent
2025.04.10
21
TypeScriptKafka 管理Flink 服务Schema RegistryConfluent 集成开发效率数据库
mcp-confluent 是一个 MCP 服务器实现，专门用于与 Confluent Kafka 和 Confluent Cloud REST APIs 进行交互。它提供了与 Confluent Cloud 平台集成的能力，支持 Kafka 集群管理、Flink 服务访问、Schema Registry 管理等核心功能。
View on GitHub
Overview
基本能力
产品定位
mcp-confluent 是一个中间件服务，旨在为 MCP 客户端（如 Claude Desktop 或 Goose CLI）提供与 Confluent Cloud 平台交互的能力。
核心功能
- 与 Confluent Kafka 和 Confluent Cloud REST APIs 交互
- 管理 Kafka 集群配置和访问
- 访问 Confluent Cloud 的 Flink 服务
- 管理 Schema Registry 数据模式
- 支持多种 MCP 客户端集成
适用场景
- 开发者在本地环境中与 Confluent Cloud 交互
- 需要自动化管理 Kafka 集群和 Flink 服务的场景
- 需要集成 Confluent 服务到 MCP 客户端的工作流中
工具列表
- Claude Desktop：桌面客户端，支持通过 MCP 服务器与 Confluent 交互
- Goose CLI：命令行工具，支持扩展集成 MCP 服务器
- MCP Inspector：开发者工具，用于测试和调试 MCP 服务器
常见问题解答
- 配置问题：确保
.env文件中所有必填变量都已正确设置 - 客户端连接问题：检查 MCP 服务器是否正常运行，端口是否正确
- 权限问题：确保 API Key 和 Secret 有足够的权限访问 Confluent 资源
使用教程
使用依赖
- 安装 Node.js（推荐使用 NVM）
nvm install 22
nvm use 22
安装教程
- 克隆项目仓库
- 安装依赖
npm install
- 创建并配置
.env文件 - 构建项目
npm run build
调试方式
- 开发模式运行
npm run dev
- 使用 MCP Inspector 测试
npx @modelcontextprotocol/inspector node --env-file $PATH_TO_PROJECT/.env /$PATH_TO_PROJECT/dist/index.js
- 生产环境运行
npm run start