跳到主要内容
版本:4.1.1

更改 KafkaBackOffException 日志级别

Doubao 中英对照 Changing KafkaBackOffException Logging Level

当重试主题中的消息尚未到消费时间时,会抛出 KafkaBackOffException。此类异常默认以 DEBUG 级别记录日志,但你可以通过在 @Configuration 类中的 ListenerContainerFactoryConfigurer 上设置错误处理器定制器来更改此行为。

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

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