← 返回目录

Confluent MCP Server

官方

让 AI 助手通过自然语言与 Confluent Cloud、Confluent Platform 及 Apache Kafka 交互的开源 MCP 服务器。

查看安装方法 ↓ 横向对比 GitHub 源仓库 ↗

分类: 数据库第 33 / 58
Stars: ★ 167 非常热门
传输方式: stdio（本地进程） · SSE · Streamable HTTP
运行环境: Node.js 22.19.0+
凭据: 可选 API Key
许可证: MIT
最近提交: 5 天前
工具数: 73

54FMRS · D

Confluent 官方开源 MCP 服务器，功能丰富，覆盖 Kafka、Flink、Schema Registry 等，但配置较复杂，且社区支持有限。

最强项 · 文档质量 14/20 最弱项 · 可靠性 6/20

可靠性

6/20

安全与权限

9/20

维护活跃度

12/20

文档质量

14/20

安装易用性

13/20

查看各项评分依据

可靠性 6/20: 仅依据 README 与仓库元数据，无法验证服务器能否实际启动、完成 MCP 初始化和工具握手；README 声称有单元/集成测试与 Docker Compose 冒烟测试，但未提供可核验的 CI 工作流或已提交的测试文件，因此按保守原则下调分数。工具列表和 CLI 输出看起来自洽，但缺乏可复现的行为证据，错误处理与边界情况也无法评估。
安全与权限 9/20: 凭据通过 YAML、环境变量、静态 API Key 和 OAuth PKCE 管理，样例配置使用占位符而非真实令牌；遥测（Sentry）有披露且支持 DO_NOT_TRACK 退出；--disable-auth 有明确警告，并实现 allowed-hosts 防 DNS 重绑定。但存在 delete-topics、delete-schema、delete-connector 等不可逆操作，README 中未说明任何二次确认机制；权限最小化、作用域划分和数据流披露的证据不足，因此给予中等偏上分数。
维护活跃度 12/20: 仓库未归档，MIT 许可证明确，具有 npm 分发迹象（版本徽章），说明基本维护仍在进行。但存在 41 个未关闭 issue，README 明确表示社区支持、无服务级别承诺，且未提供安全响应渠道、依赖更新策略或变更记录等信息，属于活跃但有治理缺口的项目，不能给予满分。
文档质量 14/20: README 结构分层，包含快速开始、完整配置指引、OAuth 说明、CLI 用法、主流客户端配置示例、遥测披露和疑难排解，且链接到 CONFIGURATION.md 等补充文档，示例配置使用占位符，整体可读性好。但缺少成本/费率或调用限制的说明，并且所有文档内容均来自不可信证据，无法独立验证其准确性，因此不给予满分。
安装易用性 13/20: 安装路径清晰：Node.js 22.19+、通过 npx/pnpm 运行、--init-config 生成配置、编辑 YAML 后 --config 启动，并提供 Claude、Cursor、VS Code、Goose 等客户端的具体配置示例，平台兼容性说明充分。但用户仍需手动填写服务地址与凭据，配置复杂度中等，且静态评审中无法看到可验证的执行证据，按校准规则上限不超过 15，故给 13。

静态评测 · 未实际运行收录于 2026-08-07

查看 FMRS 评分方法 →

选型与风险

能访问什么访问网络修改第三方账户数据

适合谁

需要与 Confluent Cloud 或 Kafka 交互的 AI 助手
使用 Confluent Platform 或本地 Kafka 的开发环境
需要统一工具集来管理 Kafka、Flink、Schema Registry 的团队

不适合谁

非 Confluent 生态的 Kafka 用户（但支持通用 Kafka，仅部分工具可用）
希望完全托管 MCP 服务器的用户（可考虑 Confluent 官方托管服务）
需要社区支持以外官方支持的用户（社区支持仅为尽力而为）

所需权限

访问 Kafka 集群的主题、消费者组、配置
执行 Flink SQL 语句并读取结果
管理 Schema Registry 中的 schemas
管理 Connectors 和 Tableflow 主题
读取 Confluent Cloud 指标和账单数据

风险与副作用

工具可执行破坏性操作（如删除主题、删除 schema），需谨慎授权
OAuth 登录凭据可能被泄露，需保护本地配置
使用 HTTP/SSE 传输时，若未设置 API 密钥，可能受到未授权访问
Tableflow 工具需要云 IAM 权限，配置不当可能导致权限错误

安装接入

准备工作

运行环境：Node.js 22.19.0+

KAFKA_API_KEY 可选密钥 Confluent Cloud Kafka API 密钥，在 Confluent Cloud 控制台创建；用于 direct 连接的 Kafka 认证（sample 配置中以 ${KAFKA_API_KEY} 插值）。

KAFKA_API_SECRET 可选密钥与 KAFKA_API_KEY 配对的密钥 Secret，同样在 Confluent Cloud 控制台生成。

SCHEMA_REGISTRY_API_KEY 可选密钥 Schema Registry 的 API 密钥，用于 HTTP Basic Auth 访问 Schema Registry。

SCHEMA_REGISTRY_API_SECRET 可选密钥与 SCHEMA_REGISTRY_API_KEY 配对的密钥 Secret。

MCP_API_KEY 可选密钥 HTTP/SSE 传输的 API 密钥，可用 --generate-key 生成后写入 config.yaml 的 server.auth.api_key。

CP_KAFKA_PASSWORD 可选密钥运行 Confluent Platform 集成测试时的 Kafka 密码（docker-compose 测试栈默认为 mcp-secret）。

其他可选配置项（3 个）

NODE_EXTRA_CA_CERTS 可选指向内部 CA 证书 bundle 的路径，遇到 TLS 握手失败时启动服务器前设置。

DO_NOT_TRACK 可选设为 true 可退出遥测数据收集（Sentry 错误上报和用量统计）。

CP_KAFKA_USERNAME 可选运行 Confluent Platform 集成测试时的 Kafka 用户名（docker-compose 测试栈默认为 mcp）。

确保 Node.js 22.19.0 或更高版本。
使用 npx @confluentinc/mcp-confluent --init-config 生成配置。
编辑 config.yaml 文件。
使用 npx @confluentinc/mcp-confluent --config ./config.yaml 启动服务器。
在 MCP 客户端中配置连接。

验证是否装好

运行 npx @confluentinc/mcp-confluent --list-tools 查看已启用的工具；连接客户端后应能看到 list-configured-connections 等始终可用的工具，调用它即可确认配置连接是否生效。

常见排障

Node.js 版本过低：升级到 22.19.0 以上
工具未出现：运行 `--list-tools` 检查工具是否启用，或调用 `explain-disabled-tools`
认证错误：使用 `--generate-key` 生成 API 密钥，并配置在 `server.auth.api_key`
端口冲突：在 `config.yaml` 中修改 `server.http.port`
Tableflow 权限错误：按文档配置 IAM 角色和策略

试试这样问

连接成功后，可以直接对 AI 助手这样说：

列出我 Kafka 集群上的所有 topic
帮我看看所有 consumer group 的消费延迟情况
搜索一下关于 Tableflow 的 Confluent 官方文档
创建一个名为 orders 的 topic，3 个分区，副本因子为 3

工具能力 73

search-product-docs 只读

搜索 Confluent 产品文档。

get-product-doc-page 只读

获取 Confluent 产品文档页面的完整内容。

explain-disabled-tools 只读

解释工具为何缺失。

list-configured-connections 只读

列出所有已配置的连接及可用工具。

config-help 只读

提供启用特定工具的配置建议。

describe-configured-connection 只读

描述一个连接的配置和工具可用性。

list-topics 只读

列出 Kafka 集群中的所有主题。

create-topics 写入

创建一个或多个 Kafka 主题，可指定分区数和副本因子。

展开其余 65 个工具

delete-topics 破坏性

删除指定名称的 Kafka 主题。

produce-message 写入

向 Kafka 主题生成消息，支持 Confluent Schema Registry 序列化。

consume-messages 只读

从 Kafka 主题消费消息，可限制分区、偏移等。

list-consumer-groups 只读

列出 Kafka 集群中的消费者组。

describe-consumer-group 只读

描述单个消费者组的状态、类型、协议等。

get-consumer-group-lag 只读

计算消费者组的偏移滞后。

alter-topic-config 写入

修改 Kafka 主题配置。

get-topic-config 只读

获取 Kafka 主题配置详情。

get-partition-offsets 只读

返回主题各分区的低/高水位和消息数。

create-flink-statement 写入

创建 Flink SQL 语句。

list-flink-statements 只读

列出 Flink SQL 语句。

get-flink-statement-results 只读

获取 Flink SQL 语句的结果行。

delete-flink-statements 破坏性

删除 Flink SQL 语句。

get-flink-statement-exceptions 只读

获取 Flink SQL 语句的最近异常。

list-compute-pools 只读

列出 Flink 计算池。

list-flink-catalogs 只读

列出 Flink 目录。

list-flink-databases 只读

列出 Flink 数据库。

list-flink-tables 只读

列出 Flink 表。

describe-flink-table 只读

获取 Flink 表的完整 schema 详情。

get-flink-table-info 只读

获取 Flink 表的元数据。

check-flink-statement-health 只读

执行 Flink SQL 语句的健康检查。

detect-flink-statement-issues 只读

检测 Flink SQL 语句的问题。

get-flink-statement-profile 只读

获取 Flink SQL 语句的查询分析数据。

list-connectors 只读

列出活跃的连接器。

get-connector-config 只读

获取连接器的完整配置。

get-connector-offsets 只读

获取连接器任务的当前偏移。

get-connector-status 只读

获取连接器及其任务的状态。

get-connector-tasks 只读

列出连接器的任务及其配置。

get-connector-error-summary 只读

汇总连接器的当前错误。

get-connector-error-recommendations 只读

获取连接器失败的补救建议。

get-connector-logs 只读

获取连接器的近期日志。

create-connector 写入

创建新连接器。

delete-connector 破坏性

删除现有连接器。

pause-connector 写入

暂停运行中的连接器及其任务。

resume-connector 写入

恢复暂停的连接器及其任务。

restart-connector 写入

重启连接器及其任务。

update-connector-config 写入

更新现有连接器的配置。

list-schemas 只读

列出 Schema Registry 中的所有 schemas。

create-schema 写入

在 Schema Registry 中注册新 schema 或新版本。

delete-schema 破坏性

从 Schema Registry 删除 schema subject 或特定版本。

search-topics-by-tag 只读

按标签列出 Kafka 集群中的主题。

search-topics-by-name 只读

按名称列出 Kafka 集群中的主题。

create-topic-tags 写入

在 Confluent Cloud 中创建新的标签定义。

delete-tag 破坏性

从 Confluent Cloud 删除标签定义。

remove-tag-from-entity 写入

从实体中移除标签。

add-tags-to-topic 写入

将现有标签分配给 Kafka 主题。

list-tags 只读

列出所有标签及其定义。

list-organizations 只读

列出当前凭据可见的 Confluent Cloud 组织。

list-environments 只读

列出 Confluent Cloud 环境。

read-environment 只读

按 ID 获取特定环境的详情。

list-clusters 只读

获取 Confluent Cloud 环境中的所有集群。

create-tableflow-topic 写入

创建 Tableflow 主题。

list-tableflow-topics 只读

列出 Tableflow 主题。

read-tableflow-topic 只读

读取 Tableflow 主题。

update-tableflow-topic 写入

更新 Tableflow 主题。

delete-tableflow-topic 破坏性

删除 Tableflow 主题。

list-tableflow-regions 只读

列出 Tableflow 区域。

create-tableflow-catalog-integration 写入

创建目录集成。

list-tableflow-catalog-integrations 只读

列出目录集成。

read-tableflow-catalog-integration 只读

读取目录集成。

update-tableflow-catalog-integration 写入

更新目录集成。

delete-tableflow-catalog-integration 破坏性

删除目录集成。

list-available-metrics 只读

列出可用的 Confluent Cloud 指标。

query-metrics 只读

查询 Confluent Cloud 指标。

list-billing-costs 只读

查询账单和成本数据。

使用场景

管理 Kafka 主题、消费者组和消息

执行 Flink SQL 查询并获取结果

管理 Schema Registry、连接器和 Tableflow

查询 Confluent Cloud 指标和账单信息

支持客户端

Claude Desktop

Claude Code

Cursor

VS Code

Goose

Gemini CLI

依据项目文档列出，未经本站实测。

详细介绍

Confluent MCP Server 是一个开源服务器，提供 50+ 工具，覆盖 Kafka、Flink SQL、Schema Registry、Connectors、Tableflow 等，帮助 AI 助手管理 Kafka 集群、执行 Flink SQL、管理 schema 和连接器。适用于 Confluent Cloud、Confluent Platform 和本地 Kafka 部署。支持多种客户端，如 Claude、Cursor、VS Code 等。