If python is the language of choice and you cannot use java, i’d recommend looking at quix-streams found here. Quix is native python and has most (if not all) of the capabilities of Apache Flink. I tried using pyflink and after two days of banging my head on the wall I found quix-streams. You will spend more time setting up your environment and debugging java dependencies than you will developing your app. When I transitioned to quix, I had my PoC built within a day.