[FLINK-36442][postgres-cdc] Add insert-only change stream option

Open nandorsoma opened this issue 1 year ago • 0 comments

Adds the option to do an insert-only stream for connectors that support specifying a changelog mode. This allows debezium connectors to be imported into flink as stream tables to take advantage of flink's strong stream processing capabilities. There is currently no way to convert a all/upsert changelog stream to an insert-only stream with just the flink table api so this appears to be the only workaround.

This PR duplicates #3562 but follows community rules. cc @henneberger

Oct 08 '24 12:10 nandorsoma