Hi Jacopo, Check this: https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/operators/asyncio.html
Best, Alex On Tue, 15 Jan 2019 at 13:57, <jacopo.go...@ubs.com> wrote: > Hi, > > > > I have a flink program which needs to process many messages and part of > this processing is to process the data using an external web service using > http calls. > > Example: > > *val *myStream: DataStream[String] > myStream > .map(*new *MyProcessingFunction) > .map(*new *MyWebServiceHttpClient) > .print > > Any suggestion? > > > > Jac > > > > > > *From:* miki haiat [mailto:miko5...@gmail.com] > *Sent:* Dienstag, 15. Januar 2019 14:03 > *To:* Gobbi, Jacopo-XT > *Cc:* user > *Subject:* [External] Re: How can I make HTTP requests from an Apache > Flink program? > > > > Can you share more which use case are you trying to implement ? > > > > > > > > On Tue, Jan 15, 2019 at 2:02 PM <jacopo.go...@ubs.com> wrote: > > Hi all, > > > > I was wondering if anybody has any recommendation over making HTTP > requests from Flink to another service. > > On the long term we are looking for a solution that is both performing and > integrates well with our flink program. > > Does it matter the library we use? Do we need a special connector to make > HTTP calls? > > One library we thought that could fit our necessities Akka akka HTTP > client API due to the possibility to make async HTTP calls. > > > > We are using Scala 2.12 and Flink 1.7. > > > > Kind regards, > > > > Jacopo Gobbi > >
