OSDir

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Async Source Function in Flink


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