返回

Spring kafka setErrorHandler不推荐更换(boot 2.6.4)

发布时间:2022-03-08 04:48:32 500

在spring boot 2.6.4上,不推荐使用这种方法。

public ConcurrentKafkaListenerContainerFactory kafkaListenerContainerFactory(
            ConcurrentKafkaListenerContainerFactoryConfigurer configurer) {
        var factory = new ConcurrentKafkaListenerContainerFactory();
        configurer.configure(factory, consumerFactory());

        // deprecated
        factory.setErrorHandler(new GlobalErrorHandler());

        return factory;
    }

全局错误处理程序类

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消息头上获得)

这不是阻塞,只是一条恼人的弃用消息。谢谢

特别声明:以上内容(图片及文字)均为互联网收集或者用户上传发布,本站仅提供信息存储服务!如有侵权或有涉及法律问题请联系我们。
举报
评论区(0)
按点赞数排序
用户头像
相关帖子