Greetings!

I’ve created a pipeline that should listen and incrementaly load records from a login table, match the info from the logged user through a JDBC lookup  and sending the enriched record to another table. the problem is that the pipeline won’t get new records after the 1st one and it keeps inserting it forever.

 here is the Query consumer config

the lookup config 

 and the the destination operation

 Thank you!!