更改 KafkaBackOffException 日志级别

当重试主题中的消息未到期消费时,会抛出 KafkaBackOffException。默认情况下,此类异常在 DEBUG 级别记录,但您可以通过在 @Configuration 类中的 ListenerContainerFactoryConfigurer 中设置错误处理程序自定义器来更改此行为。

例如,要将日志级别更改为 WARN,您可以添加

@Override
protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
    customizersConfigurer.customizeErrorHandler(defaultErrorHandler ->
            defaultErrorHandler.setLogLevel(KafkaException.Level.WARN))
}