![\"\"](\"https:\/\/codethataint.com\/blog\/wp-content\/uploads\/2025\/09\/RestData.png\")
<\/p>\n<\/p>\n
BatchConfig.java<\/strong><\/p>\n Employee.java<\/strong><\/p>\n SimpleJSONJobProcessor.java<\/strong><\/p>\n RestItemReader.java<\/strong><\/p>\n EmployeeService.java<\/strong><\/p>\n RestFileWriter.java<\/strong><\/p>\n Output<\/strong><\/p>\n BatchConfig.java @Configuration public class BatchConfig { @Autowired RestItemReader restItemReader; @Autowired ItemWriter restFileWriter; @Autowired ItemProcessor simpleJobProcessor; @Bean public Job job(JobRepository jobRepository, PlatformTransactionManager transactionManager) { return new JobBuilder("job", jobRepository) .incrementer(new RunIdIncrementer()) .start(simpleChunkStepRest(jobRepository, transactionManager)) .build(); } @Bean public Step simpleChunkStepRest(JobRepository jobRepository, PlatformTransactionManager transactionManager) { return new StepBuilder("Chunk Oriented Step", jobRepository) .<String, String>chunk(10, transactionManager) .reader(restItemReader) .processor(simpleJSONJobProcessor) .writer(restFileWriter) .build(); }… Continue reading \r\n@Configuration\r\npublic class BatchConfig {\r\n @Autowired\r\n RestItemReader restItemReader;\r\n\r\n @Autowired\r\n ItemWriter restFileWriter;\r\n\r\n @Autowired\r\n ItemProcessor simpleJobProcessor;\r\n\r\n @Bean\r\n public Job job(JobRepository jobRepository, PlatformTransactionManager transactionManager) {\r\n return new JobBuilder("job", jobRepository)\r\n .incrementer(new RunIdIncrementer())\r\n .start(simpleChunkStepRest(jobRepository, transactionManager))\r\n .build();\r\n }\r\n\r\n\r\n @Bean\r\n public Step simpleChunkStepRest(JobRepository jobRepository, PlatformTransactionManager transactionManager) {\r\n return new StepBuilder("Chunk Oriented Step", jobRepository)\r\n .<String, String>chunk(10, transactionManager)\r\n .reader(restItemReader)\r\n .processor(simpleJSONJobProcessor)\r\n .writer(restFileWriter)\r\n .build();\r\n }\r\n}\r\n\r\n<\/pre>\n\r\n@Getter\r\n@Setter\r\n@NoArgsConstructor\r\n@AllArgsConstructor\r\n@ToString\r\npublic class Employee {\r\n private Integer id;\r\n private String name;\r\n private String location;\r\n private Integer age;\r\n}\r\n<\/pre>\n\r\n@Component\r\npublic class SimpleJSONJobProcessor implements ItemProcessor<Employee, String> {\r\n @Override\r\n public String process(Employee item) throws Exception {\r\n System.out.println("Inside JSON Job Processor");\r\n\r\n String employeeDetails = "The Employee Name is " + item.getName() + ", his Age is " + item.getAge() + " and location is " + item.getLocation();\r\n\r\n return employeeDetails;\r\n }\r\n}\r\n<\/pre>\n\r\n@Component\r\npublic class RestItemReader implements ItemReader {\r\n\r\n @Autowired\r\n EmployeeService employeeService;\r\n\r\n private List<Employee> arrEmployee;\r\n\r\n @Override\r\n public Employee read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {\r\n if(arrEmployee == null){\r\n arrEmployee = employeeService.getEmpList();\r\n }\r\n\r\n if(arrEmployee != null && !arrEmployee.isEmpty()){\r\n return arrEmployee.remove(0);\r\n }\r\n\r\n return null;\r\n }\r\n}\r\n<\/pre>\n4\r\n@Service\r\npublic class EmployeeService {\r\n List<Employee> arrEmp = null;\r\n\r\n public List<Employee> getEmpList(){\r\n RestTemplate restTemplate = new RestTemplate();\r\n\r\n Employee[] employeeArray = restTemplate.getForObject("http:\/\/localhost:8080\/employee", Employee[].class);\r\n\r\n\r\n List<Employee> arrEmp = Arrays.stream(employeeArray)\r\n .collect(Collectors.toCollection(ArrayList::new));\r\n\r\n return arrEmp;\r\n }\r\n\r\n public Employee getEmployee(){\r\n if(arrEmp == null){\r\n getEmpList();\r\n }\r\n\r\n if(arrEmp != null && !arrEmp.isEmpty()){\r\n return getEmpList().remove(0);\r\n }\r\n return null;\r\n }\r\n}\r\n<\/pre>\n\r\n@Component\r\npublic class RestFileWriter implements ItemWriter<String> {\r\n @Override\r\n public void write(Chunk<? extends String> items) throws Exception {\r\n System.out.println("Inside Job Writer");\r\n items.getItems().forEach(System.out::println);\r\n }\r\n}\r\n<\/pre>\n\r\nInside JSON Job Processor\r\nInside JSON Job Processor\r\nInside JSON Job Processor\r\nInside Job Writer\r\nThe Employee Name is Mugil, his Age is 25 and location is Chennai\r\nThe Employee Name is Mani, his Age is 25 and location is Bangalore\r\nThe Employee Name is Shiva, his Age is 20 and location is Rajsatan\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"