from("{{my.app.source}}")
.unmarshal()
.bindy(BindyType.Csv, EmployeeCsvRecord.class)
.split(body())
.streaming()
.bean("employeeService", "getMap")
.aggregate(constant(true), new EmployeeAggregationStrategy())
.completionSize(500)
.log("data ready to insert into database")
.to("{{sql.insertEmployee}}")
.log("data inserted into database");
"sql:insert = into employee (employeeName, employeeAge, employeeGender, employeeDepartment, employeeSalary) values (:#employeeName, :#employeeAge, :#employeeGender, :#employeeDepartment, :#employeeSalary);batch=true"
Cannot find key [employeeName] in message body or headers to use when setting named parameter in query
I tried with batch false it is working fine. I have to do it only with sql component otherwise there are multiple ways available.