Validate supported changelog mode for flink sinks

DataSQRL / sqrl

Flexible development framework for building streaming data applications in SQL with Kafka, Flink, Postgres, GraphQL, and more.

https://www.datasqrl.com/

92 stars 12 forks source link

Validate supported changelog mode for flink sinks #810

Open henneberger opened 2 weeks ago

henneberger commented 2 weeks ago

Some sinks can only consume certain types of changelog events, for example the file and kafka connector do not support update and delete events. We should validate this behavior at compile time in sqrl.