Hello everyone, just wanted to ask a quick question: I have to retrieve data from 2 web services via REST calls, use them as sources and push these data to Kafka. So far, I implemented a SourceFunction which deals with making the calls with the respective clients.
Now, the function does use, for each REST call, Await.result(....). Do I need to use Flink's AsyncFunction instead? What are the best practices when it comes to AsyncSources? Thank you, -- Federico D'Ambrosio
