这个版本仍在开发中,目前尚未被认为是稳定的。要使用最新稳定版本,请使用 Spring for Apache Kafka 4.0.4spring-doc.cadn.net.cn

更改 KafkaBackOffException 日志级别

当重试主题中的消息不需消费时,会抛出一个KafkaBackOffException。 此类异常默认记录的日志级别为DEBUG,但你可以通过在ListenerContainerFactoryConfigurer中设置一个错误处理程序自定义器来更改此行为,该自定义器位于一个@Configuration类中。spring-doc.cadn.net.cn

例如,要将日志级别更改为 WARN,您可以添加:spring-doc.cadn.net.cn

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