Support Questions
Find answers, ask questions, and share your expertise
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Capture Change MySQL with Apache NIFI


Capture Change MySQL with Apache NIFI

New Contributor

Hi there

I'm working with capture change mysql. It working fine when i have to fetch data from tables with same structure. But I have to fetch data from huge tables with different table structures. In previous I used JsonPathReader and AvroSchemaRegistry there we have to mention column names as property names , but it is difficult in my case to mention every column name as property. I need a solution that has to get json data and execute the query with statement.type.

Here I'm uploading my workflow.