Apache Flink 
Cdc  Flink  Jdbc  Kafka  Postgres  Savepoints 

Apache Flink: Postgres to Postgres Replication with Flink CDC

Yaroslav Tkachenko Apache Flink flink postgres cdc jdbc
A practical guide to building a generic, multi-table Postgres-to-Postgres replication pipeline with Flink CDC - one replication slot for any number of tables, automatic schema discovery, and a custom pass-through deserializer that beats every built-in option for this workload.

Apache Flink: Reading and Modifying Kafka Consumer Offsets Using the State Processor API

Yaroslav Tkachenko Apache Flink flink kafka savepoints
A practical guide to inspecting and rewriting Kafka partition offsets inside Flink savepoints using the State Processor API, including the undocumented coordinator state serialization format.