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

[#1]

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?

[#2 · Accepted solution]

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