Hi Flink CDC de, I am using Flink 2.2 and Flink CDC 3.6.0 (Postgres). I am trying to take advantage of the FLIP-510 optimization to drop the

ChangelogNormalizer

from my Job Graph to save state memory. My Postgres table is configured with

REPLICA IDENTITY DEFAULT

, so deletes only contain the Primary Key. My pipeline is a pure 1:1 Upsert pipeline with no SQL transformations. Does the

flink-connector-postgres-cdc

currently support and propagate the new

keyOnlyDeletes(true)

flag (from FLIP-510) to the Flink planner?