Hi Team, We are pushing messages from Kafka to Datatorrent application using REST API service as a producer. If say due to some issue with the service the message couldn't be pushed/processed so we want to "retry it for n times" before it is dropped.
Is there any retry functionality built within Datatorrent or we have write some code logic for the same ?? Thanks!!