Identify latency bottlenecks in CDC pipeline by analyzing per-segment delays (source to Kafka, Kafka to Flink, Flink to ClickHouse) with percentile metrics and freshness. Filter by market and time window.
MIT
315,347 tools. Last updated 2026-07-28 14:53
"Apache Flink" matching MCP tools:
- Monitor consumer group lag and diagnose operational issues, detecting Flink crashes, down consumers, or uneven lag distribution.MIT
- Registers a Kafka topic as a queryable table in the Flink catalog using DDL, enabling real-time SQL queries on streaming data.Apache 2.0
- Lists all Apache Airflow DAGs with metadata including status, schedule, tags, and owners for workflow discovery and monitoring.Apache 2.0
- List installed Apache Airflow provider packages with their versions, descriptions, and included operators, hooks, and sensors. Responds to queries about provider availability and integration details.Apache 2.0
- Retrieve the Python source code of an Apache Airflow DAG by providing its DAG ID. Returns the DAG file content and file token for inspection and debugging.Apache 2.0
Matching MCP Servers
- Alicense-qualityCmaintenanceEnables interaction with Apache Flink clusters via the SQL Gateway, allowing query execution, session management, and job control through MCP tools.Last updated8Apache 2.0
- Alicense-qualityDmaintenanceEnables AI-controlled management of Apache Beam data pipelines across different runners (Flink, Spark, Dataflow, Direct) via the Model Context Protocol.Last updated4MIT
Matching MCP Connectors
SaaS intelligence for AI agents. 5 unified tools cover 1,000+ services with 91-96% token savings.
Official PicSee MCP server for short links, link management, click analytics, and optional OAuth.
- Retrieve comprehensive details for a specific Apache Airflow DAG, including schedule, pause status, owners, tags, and run configuration.Apache 2.0
- Query Shodan to find hosts matching a search term like 'apache port:443 country:US'. Supports pagination and facets for refined results.MIT
- Verify Apache Pinot connection status and retrieve diagnostics to ensure proper integration and functionality with the StarTree MCP Server.Apache 2.0
- Retrieve and manage a sorted, filtered, and paginated list of Flink SQL statements using REST API, enabling precise control over statement queries and data.MIT
- Execute SELECT SQL queries on Apache Pinot databases via the StarTree MCP Server to retrieve and analyze data efficiently.Apache 2.0
- Submit Flink SQL statements to process data streams in Confluent Cloud. Define statements with unique names, catalog, and database details for efficient execution within specified environments and compute pools.MIT
- Retrieve and analyze Flink statements and their results by querying the Flink REST API. Specify the statement name, organization, and environment to access real-time data streams or sampled results.MIT
- Remove specific Flink statements by sending requests to the Flink REST API, using organization, environment, and statement identifiers.MIT
- Build, parse, or analyze Content-Security-Policy headers with severity-ranked warnings. Assemble directives or audit existing policies for misconfigurations.MIT
- Generate Apache .htaccess file text for security, redirects, caching, compression, and access control using structured options. No file writing; returns the text for copying.MIT
- Update nginx, Apache, and PHP configuration for a FastPanel site. Supports partial updates and includes a dry-run mode to preview changes before applying.MIT
- Generates openCypher CREATE/MERGE statements to project relational tables into an Apache AGE property graph, converting rows to vertices and foreign keys to edges. Returns Cypher for review without execution.MIT
- Parse Apache, nginx, syslog, JSON Lines, and systemd journal logs into structured rows, then filter, aggregate, or convert them for analysis.MIT
- Retrieve raw nginx, apache, and PHP configuration files for a FastPanel site. Use this to inspect current settings before applying updates.MIT