To expand on @dharmendra_singh’s query, we have a pipeline set-up to fetch data from tap-postgres and load it into a target-postgres instance. We are using key-based INCREMENTAL replication for the same. We noticed two issues: