Hey Taher,
To answer question 2 and 3 - per the flink documentation[1] in-flight
requests are stored in checkpoints and only the unsent records will be sent
when recovering from a failure.
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/asyncio/#fault-tolerance-
Hi All,
I have a use case where I read from Kafkf and have some records
that I want to submit from Flink to a rest service with throttling, I
thought that the AsyncIO operator would be the best for such use cases,
however I wanted to know if AsyncIO is a stateful operator?
What I want to
