https://community.cloudera.com/t5/Support-Questions/Get-which-of-create-update-or-delete-statements-triggered/m-p/331778#M230975 <DIV class="votecell post-layout--left"><DIV class="js-voting-container d-flex jc-center fd-column ai-stretch gs4 fc-black-200"><DIV class="js-vote-count flex--item d-flex fd-column ai-center fc-black-500 fs-title c-pointer"><SPAN>In my project I am synchronizing neo4j data with mysql by using nifi to connect to kafka and neo4j plugin</SPAN><SPAN>&nbsp;</SPAN>Streams<SPAN>&nbsp;</SPAN><SPAN>to bring the data from kafka to neo4j. Inside nifi I have this structure</SPAN></DIV></DIV></DIV><DIV class="postcell post-layout--right"><DIV class="s-prose js-post-body"><PRE>Querydatabasetable -&gt; UpdateAttribute -&gt; PublishKafkaRecord</PRE><P>It triggers on any change and gets updated data, but to be able to optimize my neo4j code I need to know the type of query triggered in sql (insert, update, delete). It seems that I can't get it with<SPAN>&nbsp;</SPAN>Querydatabasetable<SPAN>&nbsp;</SPAN>processor, so which processor I should use for that purpose?</P></DIV></DIV> Wed, 08 Dec 2021 12:30:50 GMT armensano 2021-12-08T12:30:50Z https://community.cloudera.com/t5/Support-Questions/Get-which-of-create-update-or-delete-statements-triggered/m-p/331778#M230975 <DIV class="votecell post-layout--left"><DIV class="js-voting-container d-flex jc-center fd-column ai-stretch gs4 fc-black-200"><DIV class="js-vote-count flex--item d-flex fd-column ai-center fc-black-500 fs-title c-pointer"><SPAN>In my project I am synchronizing neo4j data with mysql by using nifi to connect to kafka and neo4j plugin</SPAN><SPAN>&nbsp;</SPAN>Streams<SPAN>&nbsp;</SPAN><SPAN>to bring the data from kafka to neo4j. Inside nifi I have this structure</SPAN></DIV></DIV></DIV><DIV class="postcell post-layout--right"><DIV class="s-prose js-post-body"><PRE>Querydatabasetable -&gt; UpdateAttribute -&gt; PublishKafkaRecord</PRE><P>It triggers on any change and gets updated data, but to be able to optimize my neo4j code I need to know the type of query triggered in sql (insert, update, delete). It seems that I can't get it with<SPAN>&nbsp;</SPAN>Querydatabasetable<SPAN>&nbsp;</SPAN>processor, so which processor I should use for that purpose?</P></DIV></DIV> Wed, 08 Dec 2021 12:30:50 GMT https://community.cloudera.com/t5/Support-Questions/Get-which-of-create-update-or-delete-statements-triggered/m-p/331778#M230975 armensano 2021-12-08T12:30:50Z https://community.cloudera.com/t5/Support-Questions/Get-which-of-create-update-or-delete-statements-triggered/m-p/331801#M230984 <P>I have not done that myself but CaptureChangeMySQL sounds like the processor to give you that info.&nbsp;<BR />This web page discusses how one person used that processor for tracking CDC changes from MySQL<BR /><A href="https://nikhil-suthar-bigdata.medium.com/cdc-with-apache-nifi-65020c748ff5" target="_blank">https://nikhil-suthar-bigdata.medium.com/cdc-with-apache-nifi-65020c748ff5</A></P> Wed, 08 Dec 2021 15:29:40 GMT https://community.cloudera.com/t5/Support-Questions/Get-which-of-create-update-or-delete-statements-triggered/m-p/331801#M230984 Jim_Steinebrey 2021-12-08T15:29:40Z