Hi, Besides the solution suggested by Austing, you might also want to look at Stateful Functions [1]. They provide a more convenient programming model for the use-case I think, while DataStream is a relatively low-level API.
[1] https://nightlies.apache.org/flink/flink-statefun-docs-stable/ Regards, Roman On Fri, Apr 8, 2022 at 6:56 PM Austin Cawley-Edwards <austin.caw...@gmail.com> wrote: > > Hi Jason, > > No, there is no HTTP source/ sink support that I know of for Flink. Would > running the Spring + Kafka solution in front of Flink work for you? > > On a higher level, what drew you to migrating the microservice to Flink? > > Best, > Austin > > On Fri, Apr 8, 2022 at 12:35 PM Jason Thomas <katsoftware...@gmail.com> wrote: >> >> I'm taking an existing REST based microservice application and moving all of >> the logic into Flink DataStreams. >> >> Is there an easy way to get a request/response from a Flink DataStream so I >> can 'call' into it from a REST service? For example, something similar to >> this Kafka streams example that uses Spring ReplyingKafkaTemplate - >> https://stackoverflow.com/a/58202587. >> >> Thanks for any help! >> >> -Jason >>