Search before asking I searched in the issues and found nothing similar. Flink version 1.16.2 Flink CDC version mysql cdc 2.4 Database and its version 8.0.20 Minimal reproduce step ...

A simple java program to insert and delete registries from a database using MySQL and maybe other SQL connections. I am also practicing security methods and similar stuff here ...