Thanks @Matt. Actually Jolt Transformation is the the solution worked for me (reached few days ago, I'm looking for time to write my answer 🙂 ). In my flow I route on an attribute if I want the payload or not and then I apply this Jolt spec: [{
"operation": "shift",
"spec": {
"headers": "headers",
"info": "info",
"payLoad": "payLoad"
}
}, {
"operation": "default",
"spec": {
"_kafka": {
"offset": "${kafka.offset}",
"partition": "${kafka.partition}",
"topic": "${kafka.topic}",
"key": "${kafka.key}"
},
"_nifi": {
"flowfileuuid": "${uuid}"
}
}
} ] Thanks to confirm this is the right way: I'm a newer to NiFi.
... View more
