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 ??


Reply via email to