我是新手,我需要你的帮助!
@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”来执行此操作,它适用于阅读器、处理器和分类器编写器。
我该怎么做这个流?
谢谢!