Module source 

PostgreSQL CDC source connector implementation.

Streams the changes of one primary-keyed table from PostgreSQL logical replication (pgoutput) as typed Arrow rows of the declared source schema. A fresh source claims a new slot name and creates the slot once a checkpoint commits the claim; it then either copies the table in chunks while streaming from the slot’s consistent point (snapshot.mode=initial) or starts at that point (snapshot.mode=never). Later starts resume from the engine checkpoint.

Structs

PostgresCdcSource

PostgreSQL CDC source connector.