Jaspal, If I understand this correctly, the flow looks like this.
REST API --> Kafka topic --> Apex Kafka Input Operator. If this is the flow, then the kafka input operator should be reading messages from Kafka without losing them. There is no retry attempts necessary. Let me know if the understanding of the flow is incorrect. Regards, Ashwin. On Tue, Oct 18, 2016 at 2:49 PM, Jaspal Singh <jaspal.singh1...@gmail.com> wrote: > 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!! > -- Regards, Ashwin.
