Sonia Mahi This will not handle kafka failure It need to handle separately. There is StepExecutionListener to handle step failures . When Running job you can pass parameters Then Once the job completes based on those parameters You can over written the file.