Best Apache Flink MCP Servers
Apache Flink is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applications.
Why this server?
Turns natural language into execution-verified Apache Flink SQL jobs, generating streaming pipelines with windowed aggregates, joins, late-data handling, and Kafka deployments that are verified by running against real Flink clusters.
AlicenseAqualityDmaintenanceA tool that converts natural-language requests into full, deployable, execution-verified Apache Flink SQL jobs by orchestrating an LLM to draft specs, generate Flink SQL, and verify correctness against real Flink clusters and streaming semantics—including windowed aggregates, joins, Kafka grounding, and Deployable pipelines via the generate_flink_job, ground_kafka_topic, and deploy_to_kafka tools.3Apache 2.0Why this server?
Provides read-only monitoring of Apache Flink clusters through a reachable JobManager REST endpoint. It exposes tools for cluster overview, job listing and details, exceptions, checkpoint statistics, backpressure, TaskManagers, job configuration and metrics, uploaded JARs, multi-cluster fleet overview, and one-call job diagnosis with ranked findings.
AlicenseBqualityAmaintenanceEnables read-only monitoring and diagnostics of Apache Flink clusters through a JobManager REST endpoint, including job, checkpoint, backpressure, TaskManager, and multi-cluster overviews with LLM-friendly summaries.21296 PyPI1Apache 2.0Why this server?
Provides tools to interact with Apache Flink SQL Gateway, enabling session management, SQL query execution, streaming query results, and job control.
Why this server?
Provides tools for interacting with Apache Flink clusters through the Flink REST API, enabling cluster monitoring, job listing and analysis, exception retrieval, metrics collection, TaskManager resource inspection, JAR file listing, and multi-cluster connection management.
AlicenseNot gradedqualityBmaintenanceMCP server that lets AI assistants and LLMs interact with Apache Flink clusters through natural language: cluster/job monitoring, metrics, exception tracking, TaskManager resources, and multi-cluster support via the Flink REST API.13MIT