Hi again! I did not realise both the new and old codes are supported in the later versions of the connector, but that was indeed the problem. Updated all of the options to use the new syntax and everything works like a charm.
I should've definitely been a bit more careful about that 😅 Thanks a lot for the help! -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/