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!!