Output from RichAsyncFunction on failure

Posted by Satish Saley on Jun 11, 2021; 5:40pm
URL: http://deprecated-apache-flink-mailing-list-archive.368.s1.nabble.com/Output-from-RichAsyncFunction-on-failure-tp51353.html

Hi,
- I have a kafka consumer to read events.
- Then, I have RichAsyncFunction to call a remote service to get
more information about that event.

If the remote call fails after X number of retries, I don't want flink to
fail the job and start processing from the beginning. Instead I would like
to push info about failed call to another Kafka topic. Is there a way to
achieve this?