nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bryan Bende <>
Subject Re: QueryDatabaseTable - Deleted Records
Date Fri, 15 Sep 2017 14:15:08 GMT

Typically you need to process the change log of the database in this
case, which unfortunately usually becomes database specific.

I believe we have a processor CaptureChangeMySQL that can process the
MySQL change log.


On Tue, Sep 12, 2017 at 1:39 PM, Uwe Geercken <> wrote:
> Hello,
> apparently the QueryDatabaseTable processor catches changes made to the data
> of the source database - updates and inserts.
> Has anybody a good idea or strategy how to handle deletes in the source
> database? Of course one could flag a record as deleted instead of phisically
> deleting it. But this means changing the source system in many cases and
> that is sometimes not possible. And yes, if you process the change log (if
> available) of the source system that is also a good option.
> Would be greatful for any tips or a best practive of how you do it.
> Rgds,
> Uwe

View raw message