Apache Flink MCP Server
Apache Flink MCPサーバーでClaude連携・ストリーム処理ジョブ管理を自動化
uvx flink-mcp概要
Apache Flink MCP Serverの設定方法と使い方。
分散ストリーム処理エンジン「Apache Flink」をClaudeから操作できるMCPサーバー。
FlinkクラスターのジョブモニタリングとSQL Gateway経由のクエリ実行・セッション管理が可能。
ClaudeとApache FlinkのMCPサーバー連携により、ストリーミングジョブの実行管理や異常検知・リアルタイムデータ処理の操作を自動化できる。
設定方法はFlink SQL GatewayのURLを環境変数に設定するだけでシンプルに完結する。
料金・APIキー情報
料金
完全無料APIキー
🔓 不要✅このMCPはAPIキー不要です。別途セットアップが必要な場合があります（上記参照）。
こんな使い方ができます
Apache FlinkのSQL GatewayにClaudeが接続してストリーミングSQLクエリを実行できる
実行中のFlinkジョブ一覧をClaudeが取得して状態確認やエラー診断を支援できる
Flink SQLのセッションをClaudeが管理してDDL設定や複雑なストリーム処理クエリを実行できる
クラスターのリソース使用状況をClaudeが確認してボトルネック分析と最適化提案ができる
セットアップ手順
- 1
Apache FlinkクラスターとSQL Gatewayを起動してURLを確認する（デフォルト: http://localhost:8083）
- 2
claude mcp add flink -e SQL_GATEWAY_API_BASE_URL=http://localhost:8083 -- uvx flink-mcp
設定ファイル
コピー前に確認
Apache Flinkクラスター（v1.16以上）とFlink SQL Gatewayが起動していること・Python/uvx環境が必要
claude mcp add flink -e SQL_GATEWAY_API_BASE_URL=http://localhost:8083 -- uvx flink-mcp