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
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?