we are using csv feeder to fetch the string and that will be manipulated based on the user in payloadBuilder2 function and then it will return perfect payload.
.feed(messageCsvFeeder)
.exec(
// session => {
// messageModified = session("message").as[String]
kafka("Kafka_Producer_WorkflowCaller") .send("performance",kafkaCaller.payloadBuilder2(session =>session("message").as[String]))
// session
// }
)