ch_pipeline_latency
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.
Instructions
Analyze CDC pipeline latency by segment.
Measures latency at each stage of the pipeline:
source_to_cdc: Upbit → Debezium/Kafka
cdc_to_flink: Kafka → Flink processing
flink_to_insert: Flink → ClickHouse write
end_to_end: total source_ts → inserted_at
Each segment reports p50, p95, p99, and max latency in milliseconds. Also includes data freshness (seconds behind real-time) and per-market breakdown.
Args: market: Filter by market (e.g., "KRW-BTC"). Empty = all markets period: Time window — "10m", "1h", "6h", or "24h" (default: "1h")
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| market | No | ||
| period | No | 1h |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |