остановите CaptureChangeMySQL, когда putSQL потерпел неудачу

Question

Я использую nifi для использования mysql binlog и ретрансляции sql в другую базу данных, точно так же, как репликация ведомого MySQL, поскольку binlog является последовательной. Я хочу остановить CaptureChangeMySQL в случае сбоя PutSQL, чтобы данные в целевой базе данных были подчиненнымине будет испорчен.

Я установил пороговое значение для всех объектов обратного давления всех очередей равным 1, но он не работает, все еще выполняю следующую инструкцию sql, когда PutSQL не удалось выполнить текущий sql.

Answer 1

набор Rollback On Failure = true.Если этот параметр включен, сбойные FlowFiles будут оставаться во входных отношениях, не штрафуя их и обрабатывая повторно, пока они не будут успешно обработаны или удалены другими способами.Важно установить адекватную «длительность урожая», чтобы избежать повторных попыток.

это также повлияет на все противодавления и теоретически захват будет остановлен.