kafkaitemwriter spring批处理spring boot java应用程序中的异常处理

g52tjvyc  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(386)

获取此错误:
2020-11-12 20:16:35.463错误17552---[extractor-3]o.s.k.support.loggingproducerlistener:发送带有key='defghi'和payload='{“header”:{“id”:“ururirehdjd”,“env”:“88”}等的消息到主题<topic\u name>时引发异常:
org.apache.kafka.common.errors.timeoutexception:主题<topic\u name>在60000毫秒后不在元数据中。
我的spring批处理作业是通过传递此错误来更新writecount的,即使该主题上没有发布消息。如何在这种情况下抛出异常。?

暂无答案!

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

相关问题