The replication of data based on an incrementing key (date,sequence) is awesome in nifi to replicate data between systems. Essentially every new record is converted to arvo and then propogated and inserted at other side.
But what about updates ? Deletes ? How are they handled without having to put everything through serialization mechanism on target like a queue which is hard when dealing with many objects and many ways to update/delete data. Is there a good read/article on this ? Only relevant read is this I can find http://apache-nifi-users-list.2361937.n4.nabble.com/QueryDatabaseTable-Deleted-Records-td2887.html
