更改 KafkaBackOffException 日志级别
当重试主题中的消息尚未到达消费时间时,会抛出一个 KafkaBackOffException
。此类异常默认以 DEBUG
级别记录,但您可以通过在 @Configuration
类中的 ListenerContainerFactoryConfigurer
中设置错误处理程序自定义器来更改此行为。
例如,要将日志级别更改为 WARN,您可以添加:
@Override
protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
customizersConfigurer.customizeErrorHandler(defaultErrorHandler ->
defaultErrorHandler.setLogLevel(KafkaException.Level.WARN))
}