|
该版本仍在开发中,尚未被视为稳定。对于最新稳定版本,请使用 Spring for Apache Kafka 4.0.0! |
更改KafkaBackOffException日志级别
当重试主题中的消息尚未被处理时,卡夫卡退退例外被抛出。
此类异常默认记录于调试但你可以通过在ListenerContainerFactoryConfigurer在@Configuration类。
例如,要将日志等级更改为 WARN,你可以添加:
@Override
protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
customizersConfigurer.customizeErrorHandler(defaultErrorHandler ->
defaultErrorHandler.setLogLevel(KafkaException.Level.WARN))
}