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.