Update: Apache Flink MCP Server
The
Apache Flink MCP Server
has been updated with new tools, improved documentation, and tested with multiple clients (Claude, Continue, and others).
It implements the Model Context Protocol (MCP) to enable AI assistants to interact directly with Apache Flink clusters using natural language β making stream processing easier to monitor and manage.
Available tools:
initialize_flink_connection, get_connection_status, get_cluster_info, list_jobs, get_job_details, get_job_exceptions, get_job_metrics, list_taskmanagers, list_jar_files, send_mail, get_vertex_backpressure.
Please try it out, test it with your MCP-compatible clients, and share your feedback or suggestions.
Repo:
https://github.com/Ashfaqbs/apache-flink-mcp-server