RTC MCP Server logo

RTC MCP Server

by gnuhpc

The RTC MCP Server is a Model Context Protocol (MCP) server implementation designed for managing Alibaba Cloud Realtime Compute for Apache Flink resources. It provides a standardized interface for AI models to interact with Alibaba Cloud Flink services.

View on GitHub

Last updated: N/A

What is RTC MCP Server?

The RTC MCP Server is an implementation of the Model Context Protocol (MCP) specifically tailored for managing Alibaba Cloud Realtime Compute (RTC) resources, which are based on Apache Flink. It acts as an intermediary, providing a consistent and standardized way for AI models to interact with and control Flink clusters, jobs, and deployments within the Alibaba Cloud environment.

How to use RTC MCP Server?

To use the server, you need to configure it as an MCP client in your settings file, providing the necessary command-line arguments, environment variables (including Alibaba Cloud credentials), and the path to the server's JAR file. Ensure you have the prerequisites (JDK 17+, Maven 3.6+, Alibaba Cloud account with RTC access) installed and configured. Build the project using mvn clean package and then run the server using java -jar target/rtc-mcp-server-1.0-SNAPSHOT.jar. You can then interact with the server using the available MCP tools for job, deployment, variable, workspace, and catalog management.

Key features of RTC MCP Server

  • 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

Use cases of RTC MCP Server

  • Automated deployment of Flink applications based on AI model outputs

  • Real-time monitoring and scaling of Flink jobs based on model predictions

  • Dynamic configuration of Flink jobs using variables managed by AI models

  • Simplified management of Flink resources for AI-driven data processing pipelines

FAQ from RTC MCP Server

What is the default transport mode?

The default transport mode is webflux.

How do I run the server in development mode?

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

Where are the logs located?

Logs are configured in application.yml. By default, log files are rotated daily with GZIP compression.

What are the prerequisites for running the server?

You need JDK 17 or higher, Maven 3.6 or higher, an Alibaba Cloud account with RTC access, and Alibaba Cloud Access Key ID and Secret.

How do I contribute to the project?

Fork the repository, create a feature branch, commit your changes, and create a pull request.