0

我是新手,我需要你的帮助!

@Bean
public Step csvStep() throws Exception, ParseException {
    return (stepBuilderFactory.get("csvStep").<objectDTO, objectDTO>chunk(1).reader(reader))
            .processor(processor).writer(classifierCompositeItemWriter()).faultTolerant().skipPolicy(skipPolicy)
            .skipLimit(500).listener(skipListener).listener(readerListener).listener(processListener)
            .listener(writerListener).stream(writer).stream(otherWriter).build();
}

我想将异常捕获到流(写入器)或流(erreurWriter)中以保持信息项失败。
实际上,我正在使用监听器“skipListener”来执行此操作,它适用于阅读器、处理器和分类器编写器。
我该怎么做这个流?

谢谢!

4

0 回答 0