Flink 2.0+ support

Hello team,

First of all, thank you for maintaining this project — it’s been very helpful for our Flink pipelines.

We’ve started exploring Flink 2.0 (and upcoming 2.1) in our environment and noticed that this repository currently targets Flink 1.x APIs. Would it be possible to add support for Flink 2.0+?