I have the below response from rest API call(InvokeHttpt) and I want to transform as below(wrap whole response in "responseData"), tried using JoltTransforJSON but not getting as expected. Any idea what I am missing? Any help would be appreciated. I/P { "query": { "email": "john@gmail.com", "count": 1, "created": "2017-05-17T15:40:21Z", "lang": "en-US", "responseCount": 1 }, "responseStatus": { "status": "success", "errorCode": "0", "description": "" } } Expected O/P: { "responseData": { "query": { "email": "john@gmail.com", "count": 1, "created": "2017-05-17T15:40:21Z", "lang": "en-US", "responseCount": 1 }, "responseStatus": { "status": "success", "errorCode": "0", "description": "" } } } Jolt spec I used: [ { "operation": "shift", "spec": { "query": "responseData", "*": { "@": "&" } } } ] ... View more

@Matt Burgess first of all thanks for replying my question. { "name":"John", "requestId":"123OAO0435", "email":"john@gmail.com" } Getting more complex now, in the above example 1. "name" is missing(name:isEmpty()) 2. "email" is missing(email:isEmpty()) It should create JSON like: { "requestId": "123OAO0435", "errors": [{ "errorMessage": "Name is missing" }, { "errorMessage": "Email cannot be empty" }] } If all the fields have data(name, requestId and email), then it is calling some rest api(using InvokeHttp processor). It should create JSON like: { "name":"John", "requestId":"123OAO0435", "apiResponse":{ // response from API call } } Thats the reason I was RouteOnAttribute processor, any better way to achieve this? ... View more

Thanks @Matt Burgess, that worked. Actual requirement is, I have to read some data(JSON format) from Kafka(using ConsumeKafka_ processor) and validate it and if any field missing, then I have to send(PublishKafka_) some details message about missing field. Expected JSON should contain field_1, filed_2, field_3 and filed_4 But it has field_1 and field_3( 2 and 4 are missing). I/P: {"field_1":"value_1","field_3":"value_3"} O/P: { "errors":[ { "errorMessage":"missing data field_2" }, { "errorMessage":"missing the data field_4" } ] } I am using: 1. EvaluateJsonPath (to read the json data) 2. RouteOnAttribute ( to check if empty i.e. ${FIELD_1:isEmpty()} 3. UpdateAttribute (errorMessage ${RouteOnAttribute.Route}) 4. AttributeToJSON Please let me know if you have any suggestion for my use case? Thanks again for your help. ... View more