Monitor CDC and Migration Streams in Real Time

Monitor stream health in real time, audit executed SQL, and trace run outcomes from one interface.

Runs in the same deployment and follows stream lifecycle automatically.

Observability summary

  • - Live stream stage and throughput visibility
  • - SQL query audit with classification and filters
  • - Persistent logs and run history per configuration
LIVE MONITORING

Real-Time Stream Monitoring

Follow reader and writer activity as it happens, including stage, throughput, and table progress.

Live stream monitor showing source reader, target writers, throughput, and table progress

Live monitor view with stage, rate, and table-level progress in one panel.

Pipeline Lifecycle

Initialization
Metadata Replication
Data Transfer
Target Delivery
Finished

Target Delivery becomes S3 upload only when object storage is the selected target.

Status Lifecycle

READYRUNNINGPAUSEDFINISHEDFAILEDSTOPPED

Source Reader

  • Produced row/events counters
  • Transferred data size
  • Current rate and elapsed time

Target Writers

  • Consumed row/events counters
  • Written data size
  • Average rate and active writers
SQL AUDIT

SQL Query Transparency

Track executed SQL with timing and context across streaming and schema exploration workflows.

SQL logs panel showing grouped queries, filters, durations, and expanded SQL text

SQL logs with grouped view, filtering, and expanded query details.

Every Query Tracked

  • Query purpose and execution duration
  • Row count affected or returned
  • Database, schema, and table context
  • Error state and message capture

Query Classification

Schema IntrospectionData QuerySchema ChangeDML OperationConsole Query
LOGS & HISTORY

Structured Logs and Persistent Run History

Diagnose incidents faster with searchable logs and historical run records per configuration.

System and SQL Logs

  • Filterable system and SQL log streams
  • Search and grouped log navigation
  • Export logs as JSON, CSV, or text

Run History

  • Run ID, status, and duration per execution
  • Rows processed and data-size totals
  • Historical comparison across repeated runs
System logs view with stream stage events, transfer stats, and export entries

System log timeline with stage and transfer events.

Run history table showing execution time, duration, status, rows, and data size

Persistent run history for audit and comparison.

Log export support: JSON, CSV, and plain text from UI or API.

Performance

Throughput and Target Visibility

Measure current and cumulative rate, then isolate slow tables or target-side bottlenecks.

Interval Rate

Short-term throughput in the current window

Live Rate

Current transfer speed at this moment

Average Rate

Cumulative throughput from start to now

Table-Level Statistics

  • Rows and bytes transferred per table
  • Per-table progress and elapsed duration
  • Fast isolation of slow or failed tables

Target Delivery Visibility

  • Target-side completion and write status tracking
  • Object-storage upload metrics when S3/object target is selected
  • No upload stage is shown for database targets

Ready to Stream with Full Visibility?

Monitor, audit, and diagnose every stream run from a single interface.