putSQL失败时停止CaptureChangeMySQL

Question

我使用nifi来消费mysql binlog并中继另一个数据库中的sql，就像MySQL slave复制一样，因为binlog是顺序的，所以我想在PutSQL失败的情况下停止CaptureChangeMySQL，这样slave中的目标数据库的数据就不会被弄乱。

我将所有队列的反压对象阈值都设置为1，但都不起作用，当PutSQL执行当前sql失败时，仍然执行后面的sql语句。

​

​

Answer 1

设置Rollback On Failure = true。如果启用，失败的FlowFiles将留在输入关系中，不会惩罚它，并且会被重复处理，直到它被成功处理或通过其他方式删除。设置适当的“让步持续时间”以避免过于频繁的重试是很重要的。

这也会影响所有的背压，理论上捕获将停止。