此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.2.1Spring中文文档

此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.2.1Spring中文文档

当重试主题中的消息未到期使用时,将抛出 a。 默认情况下,此类异常记录在级别,但您可以通过在类中设置错误处理程序定制器来更改此行为。KafkaBackOffExceptionDEBUGListenerContainerFactoryConfigurer@ConfigurationSpring中文文档

例如,若要将日志记录级别更改为 WARN,可以添加:Spring中文文档

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