我有一个批处理(使用SpringBatch,带有一个步骤、一个读卡器、一个处理器和一个写入器)
我的作者正在用Kafka制作人用Kafka语发送信息。
我的kafkaproducer在配置类中声明为@bean
我在我的writer中使用带有@autowired注解的kafkaproducer
由于我的步骤使用了1000个项目(我有~2m行要读),在我的steplistener的后续步骤中关闭我的制作人可以吗?
@Autowired
KafkaProducer kafkaProducer
@Override
public ExitStatus afterStep(){
kafkaProducer.close();
}
我关心的是,我只希望运行一个kafkaproducer示例,然后在步骤结束时关闭它。
这样可以吗?谢谢
暂无答案!
目前还没有任何答案,快来回答吧!