Hi Team, We recently have started a use case where there would be involvement of Kafka and Flink's low level APIs like map and process functions and since I am entirely new to these stuffs, I couldn't get the exact approach/way to test Kafka connector and low level APIs.
So can anyone share any working links/references to get started with atleast. We would be working with Pyflink for now since the use case is very limited. I would really appreciate your time. J.
