@Component
public class SimpleTasklet implements Tasklet {
    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
        System.out.println("Tasklet 방식으로 작업 수행");
        return RepeatStatus.FINISHED;
    }
}

@Bean
public Step step1(StepBuilderFactory stepBuilderFactory) {
    return stepBuilderFactory.get("step1")
        .tasklet(new SimpleTasklet())
        .build();
}

@Bean
public Job job(JobBuilderFactory jobBuilderFactory, Step step1) {
    return jobBuilderFactory.get("job")
        .start(step1)
        .build();
}

@Bean
public FlatFileItemReader<String> reader() {
    return new FlatFileItemReaderBuilder<String>()
        .name("fileReader")
        .resource(new ClassPathResource("input.txt"))
        .lineMapper(new DefaultLineMapper<String>() {
            {
                setLineTokenizer(new DelimitedLineTokenizer());
                setFieldSetMapper(new PassThroughFieldSetMapper());
            }
        })
        .build();
}

@Bean
public ItemProcessor<String, String> processor() {
    return item -> "Processed " + item;
}

@Bean
public FlatFileItemWriter<String> writer() {
    return new FlatFileItemWriterBuilder<String>()
        .name("fileWriter")
        .resource(new FileSystemResource("output.txt"))
        .lineAggregator(new PassThroughLineAggregator<>())
        .build();
}

@Bean
public Step step(StepBuilderFactory stepBuilderFactory) {
    return stepBuilderFactory.get("step")
        .<String, String>chunk(10)
        .reader(reader())
        .processor(processor())
        .writer(writer())
        .build();
}

@Bean
public Job job(JobBuilderFactory jobBuilderFactory, Step step) {
    return jobBuilderFactory.get("job")
        .start(step)
        .build();
}