|
对于最新稳定版本,请使用Spring for Apache Kafka 4.0.4! |
更改 KafkaBackOffException 日志级别
当重试主题中的消息不需消费时,会抛出一个KafkaBackOffException。
此类异常默认记录的日志级别为DEBUG,但你可以通过在ListenerContainerFactoryConfigurer中设置一个错误处理程序自定义器来更改此行为,该自定义器位于一个@Configuration类中。
例如,要将日志级别更改为 WARN,您可以添加:
@Override
protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
customizersConfigurer.customizeErrorHandler(defaultErrorHandler ->
defaultErrorHandler.setLogLevel(KafkaException.Level.WARN))
}