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?
