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