关于 Streamkap
Streamkap 是托管式 MCP 服务和命令行工具,可通过 AI Agent 管理实时变更数据捕获管道,支持创建管道、检查健康状态、诊断延迟和处理死信队列,并按所选 Streamkap 租户限定调用范围。
主要功能
- 01创建和管理 CDC 管道
- 02检查管道状态与错误
- 03调查端到端延迟
- 04处理死信队列
- 05按租户限定账户访问
适用场景
- 01将 Postgres 表连接到 Snowflake
- 02查找故障管道及近期错误
- 03调查生产环境的延迟突增
- 04按错误类别归纳近期死信消息
MCP 相关
托管 MCP 服务 `https://mcp.streamkap.com/mcp` 向兼容客户端开放 Streamkap 管道操作。OAuth 会使用所选租户;直接访问 Kafka 以及无浏览器或 CI 场景可使用 Project Key。
配置
远程服务无需本地安装。选择你使用的客户端,复制配置或使用一键安装。
https://mcp.streamkap.com/mcpclaude mcp add --transport http com-streamkap-tools https://mcp.streamkap.com/mcp{"mcpServers":{"com-streamkap-tools":{"type":"http","url":"https://mcp.streamkap.com/mcp"}}}在 Cursor 中打开{"servers":{"com-streamkap-tools":{"type":"http","url":"https://mcp.streamkap.com/mcp"}}}在 VS Code 中打开{"mcpServers":{"com-streamkap-tools":{"type":"http","url":"https://mcp.streamkap.com/mcp"}}}{"mcpServers":{"com-streamkap-tools":{"serverUrl":"https://mcp.streamkap.com/mcp"}}}命令在终端中运行;JSON 粘贴到对应客户端的 MCP 配置后重启。需要授权的服务会在首次连接时提示登录。
工具
详细介绍
Streamkap MCP
通过 AI Agent 构建、监控和排查实时 CDC 管道。
Streamkap 是面向实时数据的开发者平台。它使用变更数据捕获(CDC),在数据库发生变化时立即将变更流式传输到应用、数据仓库和 AI Agent。托管的 Streamkap MCP 服务可让你的 Agent 通过自然语言操作这一切:
- 检查管道运行状况:“哪些管道出现故障?最新错误是什么?”
- 构建管道:“将我的 Postgres 订单表连接到 Snowflake,并进行增量更新。”
- 诊断延迟:“prod-events 的端到端延迟今天早上突然增加了。发生了什么变化?”
- 排查死信队列:“找出过去一小时有消息的所有 DLQ,按错误类别分组,并建议修复方法。”
此仓库包含各 AI 客户端的插件和扩展清单,以及 Streamkap Agent 技能。服务本身托管在 https://mcp.streamkap.com/mcp:无需运行任何程序,首次使用时使用你的 Streamkap 账户登录即可。
安装
Claude
Claude.ai 和 Claude Desktop:从 Settings → Connectors 添加 Streamkap。
Claude Code:
/plugin marketplace add streamkap-com/streamkap-mcp
/plugin install streamkap@streamkap-mcp
Codex
codex plugin marketplace add streamkap-com/streamkap-mcp
codex plugin add streamkap@streamkap-mcp
Cursor
VS Code
Gemini CLI
gemini extensions install https://github.com/streamkap-com/streamkap-mcp
Kiro
Powers → Add Custom Power → Import from GitHub,然后输入 https://github.com/streamkap-com/streamkap-mcp。
仅安装 Agent 技能
npx skills add streamkap-com/streamkap-mcp
其他 MCP 客户端
{
"mcpServers": {
"streamkap": {
"type": "http",
"url": "https://mcp.streamkap.com/mcp"
}
}
}
身份验证
默认情况下,客户端会通过 OAuth 使用你的 Streamkap 账户登录,每次调用都会限定在你选择的 Streamkap 租户范围内。OAuth 会话默认禁用破坏性操作(删除和重置)。
如需直接执行 Kafka 生产和消费操作,或用于无头 Agent 和 CI,请使用 Project Key 连接,并将其放在 X-Streamkap-Project-Key 标头中发送。
此仓库包含的内容
| 路径 | 用途 |
|---|---|
plugin.json、mcp.json | Agent Plugins 客户端:Kiro、VS Code、Codex |
.claude-plugin/、.mcp.json | Claude Code 插件和市场 |
.codex-plugin/ | Codex 和 ChatGPT 插件目录 |
.cursor-plugin/ | Cursor 市场 |
gemini-extension.json、GEMINI.md | Gemini CLI 扩展 |
skills/streamkap/ | Streamkap Agent 技能 |
该技能和版本号来自 @streamkap/tools npm 包;每日工作流会在发布新版本时创建拉取请求。
链接
许可证
评论
一个开放协议,规定了 AI 应用如何以统一方式连接外部工具与数据源。客户端负责与模型对话,MCP 服务负责提供工具、资源和提示模板,两者通过标准消息通信,同一个服务可以被不同客户端复用。