RTC MCP Server

by gnuhpc

1 411 downloads Not rated yet

GitHub

Other

About

A Model Context Protocol (MCP) server implementation for managing Alibaba Cloud Realtime Computing Flink resources

Explore

- Create and manage Flink clusters
- Create and manage Flink SQL jobs
- Deploy and control Flink applications
- Monitor job status and metrics
- Create and manage savepoints
- List and manage deployments
- Workspace and namespace management

Setting up with Highlight

This MCP is not yet compatible with Highlight’s one-click setup. However, you can still use it with Highlight by following these steps:

Download and install Highlight from highlightai.com/download
Navigate to the plugins tab and select "Add Custom Plugin"
Configure the plugin with the settings below

Plugin Name RTC MCP Server

Command (node, npx, python, etc.)

Please refer to the README for specific instructions on how to obtain API keys or other required environment variables.
Enable "Start Automatically" if you want the plugin to start when Highlight launches

Setting up with Cursor

Open Cursor's settings
Navigate to the MCP section
Click "Add new Global MCP server"
Copy and paste the configuration below based on your operating system

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

Setting up with Claude Desktop

Open Claude Desktop's settings
Go to the Integrations tab
Click "Add MCP Server"
Use the configuration below based on your operating system

Note: Make sure Claude Desktop is running before attempting to connect.

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

Setting up with Windsurf

Open Windsurf's preferences
Go to the Integrations section
Click "Add MCP Integration"
Use the configuration below based on your operating system

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

Setting up with Cline

Open Cline's settings
Navigate to the Integrations section
Click "Add MCP Server"
Copy and paste the configuration below based on your operating system

Note: Make sure to restart Cline after adding the configuration.

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

Setting up with Goose

Open Goose's preferences
Go to the Integrations tab
Select "MCP Servers"
Click "Add New Server"
Use the configuration below based on your operating system

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

JSON

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

From the repository

- JDK 17 or higher
- Maven 3.6 or higher
- Alibaba Cloud account with RTC (Realtime Compute) access
- Alibaba Cloud Access Key ID and Secret

To use this server as an MCP client, add the following configuration to your MCP settings file (e.g., cline_mcp_settings.json):

{
  "mcpServers": {
    "rtc-mcp-server": {
      "command": "java",
      "args": [
        "-Dtransport.mode=stdio",
        "-Dspring.main.web-application-type=none",
        "-Dspring.main.banner-mode=off",
        "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
        "-jar",
        "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
      ],
      "env": {
        "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
        "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
      },
      "disabled": false,
      "autoApprove": []
    }
  }
}

Replace /path/to/rtc-mcp-server with your actual server path and provide your Alibaba Cloud credentials in the environment variables.

`start_job`

Start a deployed Flink job

`stop_job`

Stop a running Flink job

`list_jobs`

List all jobs in a deployment

`delete_job`

Delete a non-running job

`get_job_diagnosis`

Get job diagnosis information

`create_deployment`

Create a new Flink deployment

`get_deployment_metrics`

Get deployment metrics

`create_savepoint`

Create a savepoint for a job

`create_variable`

Create a new variable

`update_variable`

Update an existing variable

`delete_variable`

Delete a variable

`list_variables`

List variables with pagination

`create_workspace`

Create a new workspace

`get_workspace_info`

Get workspace information

`list_workspaces`

List all workspaces

`get_catalogs`

Get catalog information

`get_deployment_databases`

Get database information

`get_tables`

Get table information

`execute_sql_statement`

Execute SQL statements

The server provides the following MCP tools:

1. Job Management
- start_job: Start a deployed Flink job
- stop_job: Stop a running Flink job
- list_jobs: List all jobs in a deployment
- delete_job: Delete a non-running job
- get_job_diagnosis: Get job diagnosis information

2. Deployment Management
- create_deployment: Create a new Flink deployment
- get_deployment_metrics: Get deployment metrics
- create_savepoint: Create a savepoint for a job

3. Variable Management
- create_variable: Create a new variable
- update_variable: Update an existing variable
- delete_variable: Delete a variable
- list_variables: List variables with pagination

4. Workspace Management
- create_workspace: Create a new workspace
- get_workspace_info: Get workspace information
- list_workspaces: List all workspaces

5. Catalog Operations
- get_catalogs: Get catalog information
- get_deployment_databases: Get database information
- get_tables: Get table information
- execute_sql_statement: Execute SQL statements

Claude Desktop / Cursor

Paste into your MCP client config file to install this server.

{
    "mcpServers": {
        "rtc mcp server": {
            "rtc-mcp-server": {
                "command": "java",
                "args": [
                    "-Dtransport.mode=stdio",
                    "-Dspring.main.web-application-type=none",
                    "-Dspring.main.banner-mode=off",
                    "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
                    "-jar",
                    "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
                ],
                "env": {
                    "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
                    "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
                },
                "disabled": false,
                "autoApprove": []
            }
        }
    }
}

McpServers

{
    "rtc-mcp-server": {
        "command": "java",
        "args": [
            "-Dtransport.mode=stdio",
            "-Dspring.main.web-application-type=none",
            "-Dspring.main.banner-mode=off",
            "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
            "-jar",
            "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
        ],
        "env": {
            "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
            "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
        },
        "disabled": false,
        "autoApprove": []
    }
}

A Model Context Protocol (MCP) server implementation for managing Alibaba Cloud Realtime Compute for Apache Flink resources. This server provides a standardized interface for AI models to interact with Alibaba Cloud Flink services.

Features

Prerequisites

- JDK 17 or higher
- Maven 3.6 or higher
- Alibaba Cloud account with RTC (Realtime Compute) access
- Alibaba Cloud Access Key ID and Secret

Client Configuration

To use this server as an MCP client, add the following configuration to your MCP settings file (e.g., cline_mcp_settings.json):

{
  "mcpServers": {
    "rtc-mcp-server": {
      "command": "java",
      "args": [
        "-Dtransport.mode=stdio",
        "-Dspring.main.web-application-type=none",
        "-Dspring.main.banner-mode=off",
        "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
        "-jar",
        "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
      ],
      "env": {
        "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
        "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
      },
      "disabled": false,
      "autoApprove": []
    }
  }
}

Replace /path/to/rtc-mcp-server with your actual server path and provide your Alibaba Cloud credentials in the environment variables.

Available Tools

The server provides the following MCP tools:

2. Deployment Management
- create_deployment: Create a new Flink deployment
- get_deployment_metrics: Get deployment metrics
- create_savepoint: Create a savepoint for a job

4. Workspace Management
- create_workspace: Create a new workspace
- get_workspace_info: Get workspace information
- list_workspaces: List all workspaces

Build and Run

1. Build the project:

mvn clean package

2. Run the server:

java -jar target/rtc-mcp-server-1.0-SNAPSHOT.jar

For development mode with stdio transport:

java -Dtransport.mode=stdio -Dspring.main.web-application-type=none -jar target/rtc-mcp-server-1.0-SNAPSHOT.jar

Server Modes

The server supports multiple transport modes:
- webflux: Default mode using Spring WebFlux
- stdio: Command-line mode for development and testing

Logging

Logs are configured in application.yml with the following default settings:
- Root level: WARN
- Application level (com.rtc): INFO
- Log files are rotated daily with GZIP compression

Contributing

1. Fork the repository
2. Create a feature branch
3. Commit your changes
4. Create a pull request

License

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

No reviews yet — be the first

Use Google, GitHub, or an email account so ratings stay tied to real people.

Email sign in

No reviews posted yet.

About

Explore

Setting up with Highlight

From the repository

start_job

stop_job

list_jobs

delete_job

get_job_diagnosis

create_deployment

get_deployment_metrics

create_savepoint

create_variable

update_variable

delete_variable

list_variables

create_workspace

get_workspace_info

list_workspaces

get_catalogs

get_deployment_databases

get_tables

execute_sql_statement

Claude Desktop / Cursor

McpServers

Features

Prerequisites

Client Configuration

Available Tools

Build and Run

Server Modes

Logging

Contributing

License

More like this

Sequential Thinking

Filesystem

EverArt

Google Drive

`start_job`

`stop_job`

`list_jobs`

`delete_job`

`get_job_diagnosis`

`create_deployment`

`get_deployment_metrics`

`create_savepoint`

`create_variable`

`update_variable`

`delete_variable`

`list_variables`

`create_workspace`

`get_workspace_info`

`list_workspaces`

`get_catalogs`

`get_deployment_databases`

`get_tables`

`execute_sql_statement`