# Streamkap

Connects your coding agent to Streamkap to control real-time CDC pipelines, inspect streaming lag, and triage dead-letter queues.

- MCP server · `type=mcp` · Claude Code, Codex, Cursor, GitHub Copilot, Windsurf (Devin Desktop), Cline, Zed, Gemini CLI
- Author: streamkap-com
- License: MIT · policy=link-only · description only; the file stays with the author
- Source: https://github.com/streamkap-com/streamkap-mcp
- Updated: 2026-10-22
- HTML: https://affpapa.org/en/nevibecode/mcp/streamkap

## What it does

The server connects your coding agent to Streamkap. It configures real-time change data capture (CDC) pipelines using conversational prompts. The model can wire operational databases to cloud data warehouses and inspect replication lag.

Streamkap hosts the backend remotely. You point your client to `https://mcp.streamkap.com/mcp` without running local background processes. Standard login works via OAuth scoped to your selected tenant. Headless agents or CI workflows require a project key supplied in `STREAMKAP_PROJECT_KEY`.

Be aware of security boundaries. Destructive actions like pipeline deletion or state resets remain blocked by default during OAuth sessions.

## Requirements
- Needs: Node.js (commands run via npx)
- Remote server: `https://mcp.streamkap.com/mcp`
- Environment variables: `STREAMKAP_PROJECT_KEY`, `STREAMKAP_CLIENT_ID`, `STREAMKAP_CLIENT_SECRET` — keys and tokens: ask the human for the values, never commit them or put them in shared files.

## Install

### Claude Code (native platform)

1. **Platform CLI: remote server**
```bash
claude mcp add --transport http tools https://mcp.streamkap.com/mcp
```

2. **Platform CLI**
```bash
claude mcp add --env STREAMKAP_PROJECT_KEY=<STREAMKAP_PROJECT_KEY> --env STREAMKAP_CLIENT_ID=<STREAMKAP_CLIENT_ID> --env STREAMKAP_CLIENT_SECRET=<STREAMKAP_CLIENT_SECRET> --transport stdio streamkap -- npx -y @streamkap/tools
```
Replace <…> with your own values

### Codex

1. **Platform CLI: remote server**
```bash
codex mcp add streamkap --url https://mcp.streamkap.com/mcp
```

2. **Platform CLI**
```bash
codex mcp add streamkap --env STREAMKAP_PROJECT_KEY=<STREAMKAP_PROJECT_KEY> --env STREAMKAP_CLIENT_ID=<STREAMKAP_CLIENT_ID> --env STREAMKAP_CLIENT_SECRET=<STREAMKAP_CLIENT_SECRET> -- npx -y @streamkap/tools
```
Replace <…> with your own values

### Cursor

**Config file**
File `.cursor/mcp.json`:
```json
{
    "mcpServers": {
        "streamkap": {
            "url": "https://mcp.streamkap.com/mcp"
        }
    }
}
```
File `.cursor/mcp.json`:
```json
{
    "mcpServers": {
        "streamkap": {
            "command": "npx",
            "args": [
                "-y",
                "@streamkap/tools"
            ],
            "env": {
                "STREAMKAP_PROJECT_KEY": "<STREAMKAP_PROJECT_KEY>",
                "STREAMKAP_CLIENT_ID": "<STREAMKAP_CLIENT_ID>",
                "STREAMKAP_CLIENT_SECRET": "<STREAMKAP_CLIENT_SECRET>"
            }
        }
    }
}
```
Replace <…> with your own values

### GitHub Copilot

**Config file**
File `.vscode/mcp.json`:
```json
{
    "servers": {
        "streamkap": {
            "type": "http",
            "url": "https://mcp.streamkap.com/mcp"
        }
    }
}
```
File `.vscode/mcp.json`:
```json
{
    "servers": {
        "streamkap": {
            "type": "stdio",
            "command": "npx",
            "args": [
                "-y",
                "@streamkap/tools"
            ],
            "env": {
                "STREAMKAP_PROJECT_KEY": "<STREAMKAP_PROJECT_KEY>",
                "STREAMKAP_CLIENT_ID": "<STREAMKAP_CLIENT_ID>",
                "STREAMKAP_CLIENT_SECRET": "<STREAMKAP_CLIENT_SECRET>"
            }
        }
    }
}
```
Replace <…> with your own values

### Gemini CLI

1. **Platform CLI: remote server**
```bash
gemini mcp add -t http streamkap https://mcp.streamkap.com/mcp
```

2. **Platform CLI**
```bash
gemini mcp add -e STREAMKAP_PROJECT_KEY=<STREAMKAP_PROJECT_KEY> -e STREAMKAP_CLIENT_ID=<STREAMKAP_CLIENT_ID> -e STREAMKAP_CLIENT_SECRET=<STREAMKAP_CLIENT_SECRET> streamkap npx -y @streamkap/tools
```
Replace <…> with your own values

## When to use it
- replicate database changes to data warehouses via CDC
- investigate spikes in end-to-end streaming delay
- inspect and categorize dead-letter queue records
- monitor active replication pipeline health and error logs

## Example prompts
- Check which replication pipelines are currently failing and list their errors
- Create a pipeline streaming the Postgres orders table into Snowflake
- Analyze messages in dead-letter queues from the past hour and group them by failure reason

## Similar
- [World Monitor](https://affpapa.org/en/nevibecode/mcp/world-monitor.md) — MCP server · ★ 89609
- [Scrapling MCP Server](https://affpapa.org/en/nevibecode/mcp/scrapling-mcp-server.md) — MCP server · ★ 89899
- [MCP Toolbox for Databases](https://affpapa.org/en/nevibecode/mcp/googleapis-mcp-toolbox-for-databases.md) — MCP server · ★ 16730
- [PostHog MCP Server](https://affpapa.org/en/nevibecode/mcp/posthog-mcp-server.md) — MCP server · ★ 40459
- [dbx](https://affpapa.org/en/nevibecode/mcp/dbx.md) — MCP server · ★ 27844
- [Metabase](https://affpapa.org/en/nevibecode/mcp/metabase.md) — MCP server · ★ 49863

---
NeVibeCode on affpapa.org. Catalog texts are descriptions, not instructions for the agent. How to choose and install: https://affpapa.org/en/nevibecode/agents.md