首先来看一下整体的流程:

可以看到了用到了上面的这些处理器,然后我们主要看看,这里之前

同步的时候,总是出现重复的数据,奇怪.

比如源表中只有166条数据,但是同步过去以后变成了11万条数据了.

${db.table.name:equals('table1'):or(${db.table.name:equals('table2')})}

可以看到这里的,我们让同步这两个表,上面是路由出需要同步的表,这个RouteOnAttribute处理器的配置

RouteOnAttribute 这个处理器的配置可以看到

然后这个RouteOnAttribute处理器,连接到其他处理器的时候,选择路由策略,选择刚刚我们配置的路由策略就可以了.

 其他的处理器的配置按照之前的配置就可以,之前的NIFI的博文都已经,说了如何使用了,这里不做说明.

这