Hi Guy,
Most Flink CDC connectors are distributed as both “thin" and “fat" jars [1].
Fat jars (with names like flink-sql-connector-mysql-cdc) have all external
dependencies bundled inside, mainly used for Flink Table SQL jobs. Thin jars
(with names like flink-connector-mysql-cdc) are mostly use
I am new to Flink and the days I used java was long ago. I am trying to write
a Flink app that utilizes Table API with a source table used the MySQL CDC
connector 3.3.0 to talk to a Postgres table using JDBC driver. I am using
Gradle to build a shadowJar which I submit to my Flink containers by
