CDC ingests

Use this reference to monitor the state, progress, and errors of CDC table ingestion through the information schema.

Private Preview Feature

This feature is currently in private preview. Contact [e-mail] to request early access.

The information_schema.cdc_ingests view reports the live state of CDC table ingestion: one row per CDC table with an active ingest worker. The state comes from the workers themselves, so query the view on the engine where ingestion runs (the engine that executed ALTER CDC TABLE ... RESUME); on other engines the view is empty.

SELECT table_name, stream_name, state, phase,
       apply_count, last_commit_time, live_lag_ms, last_error, error_count
FROM information_schema.cdc_ingests;

Columns in information_schema.cdc_ingests

Column Name	Data Type	Description
database_name	TEXT	The database containing the CDC table.
schema_name	TEXT	The schema containing the CDC table.
table_name	TEXT	The CDC table.
stream_name	TEXT	The stream feeding the table.
engine_id	TEXT	The engine running the ingest worker.
state	TEXT	Derived rollup: backfilling, streaming, or error (streaming with recent failures).
phase	TEXT	Ingest phase: backfilling (initial snapshot) or streaming (applying the change feed).
apply_count	BIGINT	Number of batches applied since the worker started.
last_commit_time	TIMESTAMPTZ	When the worker last committed a batch.
live_lag_ms	BIGINT	Milliseconds since the worker last advanced. A steadily growing value while state is streaming signals a stalled feed.
last_error	TEXT	The most recent failure message; NULL if none.
error_count	BIGINT	Number of failed ingest attempts since the worker started.

Examples

Check ingestion health

SELECT table_name, state, live_lag_ms, last_error
FROM information_schema.cdc_ingests
WHERE state = 'error' OR live_lag_ms > 60000;

Watch a backfill progress

SELECT table_name, phase, apply_count, last_commit_time
FROM information_schema.cdc_ingests
WHERE table_name = 'orders';

Related

• CDC tables: lifecycle and monitoring.
• CREATE CDC TABLE: DDL reference, including ALTER CDC TABLE RESUME | SUSPEND | CASCADE.
• information_schema.streams: stream metadata.