Solved
Go to solution
1 ACCEPTED SOLUTION
@manisha jain
Yeah you can manipulate results coming out from your Query database processor itself.
if you want to add static fields to the each avro record then in your Querydatabase processor.
change Columns to return property as
*,'in' type //return all columns from table and add type column with value in for each row.
Processor Config:-
as you can view above screenshot how we are configuring Columns to Return property above.
(or)
Another way doing this is
Once you get results from Query database processor then
1.Use convertavrotojson processor //we are converting avro data into json. 2.Use ReplaceText processor //to search for literal value } and do replacement value as your desired value in jsonformat ex:- ,"type":"in"} in this processor using replace text we are having json array of records and we are looking for } that means at end of each record and we are going to replace with ,"type":"in"} for each record so the json record structure will wont change. 3.Use convertjsontoavro processor //we are converting json data into avro data again and this data having new field that we have added to the json message.
