Apache Flink CDC Stream Processing Services

# Query running Flink CDC job checkpoint health and alignment delay
curl -s http://localhost:8081/jobs | jq -r '.jobs[] | select(.status=="RUNNING") | .id' | while read job_id; do
  curl -s "http://localhost:8081/jobs/${job_id}/checkpoints" | jq '{
    job_id: "'${job_id}'",
    latest_checkpoint_type: .latest.completed.checkpoint_type,
    duration_ms: .latest.completed.end_to_end_duration,
    state_size_mb: (.latest.completed.state_size / 1048576 | floor),
    alignment_buffered_bytes: .latest.completed.alignment_buffered,
    failed_checkpoints: .counts.failed
  }'
done

-- Inspect active Flink CDC reader connections, wait events, and transaction duration
SELECT pid,
       usename,
       client_addr,
       state,
       wait_event_type,
       wait_event,
       NOW() - query_start AS query_duration,
       query
FROM pg_stat_activity
WHERE application_name LIKE '%flink%' OR application_name LIKE '%debezium%'
ORDER BY query_start ASC;