|
对于最新的稳定版本，请使用 Spring for Apache Kafka 3.2.1！ |
|
对于最新的稳定版本，请使用 Spring for Apache Kafka 3.2.1！ |
当重试主题中的消息未到期使用时，将抛出 a。
默认情况下，此类异常记录在级别，但您可以通过在类中设置错误处理程序定制器来更改此行为。KafkaBackOffExceptionDEBUGListenerContainerFactoryConfigurer@Configuration
例如，若要将日志记录级别更改为 WARN，可以添加：
@Override
protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
customizersConfigurer.customizeErrorHandler(defaultErrorHandler ->
defaultErrorHandler.setLogLevel(KafkaException.Level.WARN))
}