关闭Kafka制作人的位置

hmtdttj4  于 2021-08-20  发布在  Java
关注(0)|答案(0)|浏览(202)

我有一个批处理(使用SpringBatch,带有一个步骤、一个读卡器、一个处理器和一个写入器)
我的作者正在用Kafka制作人用Kafka语发送信息。
我的kafkaproducer在配置类中声明为@bean
我在我的writer中使用带有@autowired注解的kafkaproducer
由于我的步骤使用了1000个项目(我有~2m行要读),在我的steplistener的后续步骤中关闭我的制作人可以吗?

@Autowired
KafkaProducer kafkaProducer

@Override
public ExitStatus afterStep(){
  kafkaProducer.close();
}

我关心的是,我只希望运行一个kafkaproducer示例,然后在步骤结束时关闭它。
这样可以吗?谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题