apache storm - Kafka Spout number of retries -


I am using storm 0.8.2 with ack mechanism and I have nothing about failing and trying again The questions are:

  1. Can I limit the number of retiaries?
  2. How can I handle the error on my own? I want to try again on some errors (for example, the database does not answer) and I do not want to try again on other (like there is an error parsing the tuple).

Can I limit the number of retries?

Not a built-in feature you should apply logic to your spout for this.

How do I control errors? Meaning for some errors (i.e. DB is not responding) I want to try again and for others (i.e. to pars the error pipe) I do not want to try again.

I would recommend to read the complete storm document and in particular, otherwise, I will post it here. Once you understand how Storm handles processing, then Will be really easy to implement.


Comments