
Postgres CDC to Iceberg on Google Cloud Lakehouse with OLake Go
Stream Postgres CDC into Apache Iceberg tables on Google BigLake with OLake Go and query live data in BigQuery. A step-by-step setup with no Kafka or Spark.
Blogs on the topic Change Data Capture
View All Tags
Stream Postgres CDC into Apache Iceberg tables on Google BigLake with OLake Go and query live data in BigQuery. A step-by-step setup with no Kafka or Spark.

OLake Go can now write Iceberg v3 deletion vectors for upserts and CDC. From immutable Parquet and merge-on-read to equality and positional deletes—and why bitmap deletion vectors close the gap with query engines.

Learn how to replicate PostgreSQL CDC data to Apache Iceberg without Spark using Kafka, Flink, or OLake, including setup, architecture, and best practices.

Equality deletes, position deletes, and deletion vectors compared for CDC pipelines: what each stores, which query engines can read them, what compaction fixes, and the table properties to set explicitly.

OLake Go architecture deep dive: eight sources, one sync engine, chunked parallel backfills, native CDC, state and the Arrow write path to Iceberg.

OLake Go schema evolution into Apache Iceberg: automatic column adds, retained drops, safe type promotions, and failures only where data would corrupt.