I published a new Flink tutorial demonstrating how you can efficiently combine a Flink CDC Postgres source with a JDBC sink to get Postgres-to-Postgres replication. Tutorial: https://streamacademy.io/tutorial/flink-postgres-cdc-replication/ Source code: https://github.com/irontools/flink-tutorials/tree/main/postgres-replication