mcpField
S
Streamkap

Streamkap

リモート
streamkap.comデータベース06 日前に更新
リポジトリ公式サイト

Streamkap について

Streamkap は、AI エージェントからリアルタイムの変更データキャプチャパイプラインを管理する、ホスト型 MCP サーバーとコマンドラインツールです。パイプラインの作成、状態確認、遅延診断、デッドレターキューの調査に対応し、操作は選択した Streamkap テナントに限定されます。

主な機能

  1. 01CDC パイプラインの作成と管理
  2. 02パイプラインの状態とエラー確認
  3. 03エンドツーエンド遅延の調査
  4. 04デッドレターキューのトリアージ
  5. 05テナント単位のアカウントアクセス

活用シーン

  1. 01Postgres テーブルを Snowflake に接続
  2. 02失敗したパイプラインと直近のエラーを特定
  3. 03本番環境の遅延急増を調査
  4. 04直近のデッドレターメッセージをエラー別に分類

MCP 対応

ホスト型 MCP サーバー `https://mcp.streamkap.com/mcp` は、互換クライアントに Streamkap のパイプライン操作を公開します。OAuth は選択したテナントを使用し、Kafka の直接利用やブラウザーなしの環境、CI では Project Key を利用できます。

設定

リモートサーバーはインストール不要です。クライアントを選んで設定をコピーするか、ワンクリックで導入できます。

エンドポイントhttps://mcp.streamkap.com/mcp
インストールコマンドをコピー
Claude CodeTerminal
Cursor.cursor/mcp.json
VS Code.vscode/mcp.json
Claude Desktopclaude_desktop_config.json
Windsurf~/.codeium/windsurf/mcp_config.json

コマンドはターミナルで実行し、JSON は各クライアントの MCP 設定に貼り付けて再起動します。認可が必要なサーバーは初回接続時にログインを求めます。

パッケージ
npm@streamkap/tools0.10.0

ツール

詳細

Streamkap MCP

Streamkap

AI エージェントから、リアルタイム CDC パイプラインを構築、監視、トラブルシューティングできます。

Streamkap は、リアルタイムデータのための開発者向けプラットフォームです。変更データキャプチャ(CDC)を使用して、データベースの変更を発生した瞬間にアプリ、データウェアハウス、AI エージェントへストリーミングします。ホスト型の Streamkap MCP サーバーを使うと、エージェントから自然言語ですべてを操作できます。

  • パイプラインの状態を確認:「失敗しているパイプラインはどれですか? 最新のエラーも教えてください」
  • パイプラインを構築:「Postgres の orders テーブルを Snowflake に接続して、増分更新を行ってください」
  • 遅延を診断:「今朝、prod-events のエンドツーエンドの遅延が急増しました。何が変わりましたか?」
  • デッドレターキューをトリアージ:「過去 1 時間にメッセージがある DLQ をすべて探し、エラーの種類ごとにまとめて、修正案を提示してください」

このリポジトリには、各 AI クライアント用のプラグインと拡張機能のマニフェストに加え、Streamkap エージェントスキルが含まれています。サーバー自体は 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

Cursor に追加

VS Code

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 を入力します。

エージェントスキルのみ
npx skills add streamkap-com/streamkap-mcp
その他の MCP クライアント
{
  "mcpServers": {
    "streamkap": {
      "type": "http",
      "url": "https://mcp.streamkap.com/mcp"
    }
  }
}

認証

デフォルトでは、クライアントは Streamkap アカウントで OAuth を通じてサインインし、各呼び出しは選択した Streamkap テナントに限定されます。OAuth セッションでは、破壊的な操作(削除とリセット)はデフォルトで無効になっています。

Kafka への直接のデータ生成とデータ消費、またはヘッドレスエージェントや CI で利用する場合は、代わりに Project Key を X-Streamkap-Project-Key ヘッダーで送信して接続します。

このリポジトリの内容

パス対象
plugin.json, mcp.jsonAgent Plugins クライアント:Kiro、VS Code、Codex
.claude-plugin/, .mcp.jsonClaude Code プラグインとマーケットプレイス
.codex-plugin/Codex と ChatGPT プラグインディレクトリ
.cursor-plugin/Cursor Marketplace
gemini-extension.json, GEMINI.mdGemini CLI 拡張機能
skills/streamkap/Streamkap エージェントスキル

スキルとバージョン番号は @streamkap/tools npm パッケージから取得され、新しいバージョンが公開されると、毎日のワークフローがプルリクエストを作成します。

リンク

ライセンス

MIT

コメント

MCP は初めてですか?

プロトコルの概要から最初のサーバーの導入まで、よくある疑問にまとめて答えます。

AI アプリケーションが外部のツールやデータソースに統一的な方法で接続するためのオープンなプロトコルです。クライアントはモデルとの対話を担い、MCP サーバーはツール・リソース・プロンプトテンプレートを提供します。標準メッセージでやり取りするため、1 つのサーバーを複数のクライアントで再利用できます。