Hey, I'd like to consume the postgres-cdc connector with an insert-only changelog. I'm uninterested in any retraction messages since our use case doesn't require it, and we can greatly benefit from the flink operations that insert-only changelog provides. E.g. I want to do a tumble window aggregation on the stream of events. We're using the table api exclusively and there's no way to convert a different changelog stream to an insert only stream so I'm pushing this upstream to the connector. I threw up a PR to showcase the implementation. Let me know what you think of this.
Thanks, Daniel Henneberger https://github.com/apache/flink-cdc/pull/3562
