Support Questions
Find answers, ask questions, and share your expertise

Get which of create, update or delete statements triggered Querydatabasetable in nifi

Explorer
In my project I am synchronizing neo4j data with mysql by using nifi to connect to kafka and neo4j plugin Streams to bring the data from kafka to neo4j. Inside nifi I have this structure
Querydatabasetable -> UpdateAttribute -> PublishKafkaRecord

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 Querydatabasetable processor, so which processor I should use for that purpose?

1 ACCEPTED SOLUTION

New Contributor

I have not done that myself but CaptureChangeMySQL sounds like the processor to give you that info. 
This web page discusses how one person used that processor for tracking CDC changes from MySQL
https://nikhil-suthar-bigdata.medium.com/cdc-with-apache-nifi-65020c748ff5

View solution in original post

1 REPLY 1

New Contributor

I have not done that myself but CaptureChangeMySQL sounds like the processor to give you that info. 
This web page discusses how one person used that processor for tracking CDC changes from MySQL
https://nikhil-suthar-bigdata.medium.com/cdc-with-apache-nifi-65020c748ff5

Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.