Нужно ли останавливать NiFi, когда мы динамически обновляем существующий WorkFlow?

Question

В моем существующем рабочем процессе NiFi у меня есть следующие scenerio: 1) Возможно, мне придется динамически добавлять новую тему Кафки. 2) Возможно, мне придется добавить новый маршрут. 3) Мне может понадобиться добавить новый процессор (не уверен, что в потоке мы можем добавить новый процессор!)

У меня вопрос: если мой рабочий процесс NiFi запущен в рабочем режиме, нужно ли мне останавливать и перезапускать его, когда я динамически (на лету) обновляю рабочий процесс?

В каком сценарии мне нужно его сбить? Благодарю.

Answer 1

Вам не нужно перезапускать весь экземпляр NiFi, но некоторые изменения могут потребовать остановки и запуска определенного процессора. Например, если у вас есть процессор ConsumeKafka со списком тем, вам придется его остановить, добавить новую тему в свойство и запустить ее снова. Вы можете написать эти операции с помощью REST API.