获取此错误:
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的,即使该主题上没有发布消息。如何在这种情况下抛出异常。?
暂无答案!
目前还没有任何答案,快来回答吧!