Spring kafka setErrorHandler不推荐更换(boot 2.6.4)
发布时间:2022-03-08 04:48:32 511
相关标签:
在spring boot 2.6.4上,不推荐使用这种方法。
public ConcurrentKafkaListenerContainerFactory
全局错误处理程序类
public class GlobalErrorHandler implements ConsumerAwareErrorHandler {
private static final Logger log = LoggerFactory.getLogger(GlobalErrorHandler.class);
@Override
public void handle(Exception thrownException, ConsumerRecord, ?> data, Consumer, ?> consumer) {
// my custom global logic (e.g. notify ops team via slack)
}
}
这个的替换样品是什么?医生说我应该用setCommonErrorHandler
,但如何实现CommonErrorHandler
接口,因为没有要重写的方法。
重点是,我必须根据特定条件向ops团队发送松弛通知(消息tpye,可在kafka消息头上获得)
这不是阻塞,只是一条恼人的弃用消息。谢谢
特别声明:以上内容(图片及文字)均为互联网收集或者用户上传发布,本站仅提供信息存储服务!如有侵权或有涉及法律问题请联系我们。
举报