Я пишу из памяти здесь, поэтому, пожалуйста, попробуйте это на непроизводственном кластере, прежде чем пойти и сделать это и обнаружить, что я что-то неправильно запомнил.
Если ваши топологии написаны для обработки потери сообщений (т.е.они либо не заботятся, по крайней мере, один раз, либо вы используете acking), вы можете просто убить руководителя и работников.Нимбус выяснит, что руководитель мертв, и перенастроит исполнителей довольно быстро.Когда появятся новые исполнители, топологии будут обрабатывать потерянные сообщения, поскольку они не были подтверждены.
Если вы не можете справиться с потерей сообщений, вы можете деактивировать топологии в пользовательском интерфейсе Storm, дождитесь их остановкиобработка и убить руководителя.Затем повторно активируйте топологии, и Nimbus переназначит их.