Кафка Носик числа повторных попыток

Question

Я использую шторм 0.8.2 с механизмом Ack и у меня есть несколько вопросов по поводу неудачи и повторить:

1. Могу ли я ограничить число повторных попыток?
2. Как я могу обрабатывать ошибки самостоятельно? При некоторых ошибках я хочу повторить попытку (например, база данных не отвечает), а в других случаях я не хочу повторять попытку (например, при разборке кортежа есть ошибка).

Answer 1

Могу ли я ограничить количество попыток?

Не встроенный особенность. Вы должны реализовать логику этого в своем носике.

Как я могу контролировать ошибки? значение для некоторых ошибок (т. е. db не отвечает) Я хочу повторить попытку и для другого (т. е. ошибку для синтаксического разбора). Я не хочу повторять попытку.

Я бы рекомендовал прочитать всю документацию Storm и, в частности, Guaranteeing Message Processing. В противном случае я бы перепечатал его здесь. Как только вы поймете, как Storm обрабатывает обработку сообщений, она станет очень простой в реализации.