参见Spring for Apache Kafka文档;传统错误处理程序被CommonErrorHandler实现所取代。

最新消息

https://docs.spring.io/spring-kafka/docs/current/reference/html/#x28-eh
旧版GenericErrorHandler及其用于记录批处理监听程序的子接口层次结构已被新的单个接口CommonErrorHandler所取代，该接口的实现与GenericErrorHandler的大多数旧版实现相对应。有关详细信息，请参阅容器错误处理程序。

容器错误处理程序

https://docs.spring.io/spring-kafka/docs/current/reference/html/#error-handlers
从版本2.8开始，旧的ErrorHandler和BatchErrorHandler接口已被新的CommonErrorHandler取代。这些错误处理程序可以处理记录监听器和批处理监听器的错误。从而允许单个监听器容器工厂为两种类型的监听器创建容器。提供了CommonErrorHandler实现以替换大多数旧框架错误处理程序实现，旧错误处理程序已弃用。侦听器容器和侦听器容器工厂仍然支持遗留接口;在将来的版本中将不建议使用它们。

我遇到了完全相同的问题，所以我将方法实现ConsumerAwareErrorHandler更改为
常见错误处理程序
并得到执行
句柄记录
就像文档中描述的那样，它起作用了！

public class GlobalErrorHandler implements CommonErrorHandler {

  private static final Logger log = LoggerFactory.getLogger(GlobalErrorHandler.class);

  @Override
  public void handleRecord(
      Exception thrownException,
      ConsumerRecord<?, ?> record,
      Consumer<?, ?> consumer,
      MessageListenerContainer container) {
    log.warn("Global error handler for message: {}", record.value().toString());
  }
}

在Kafka配置类中

@Bean(value = "kafkaListenerContainerFactory")
  public ConcurrentKafkaListenerContainerFactory<Object, Object> kafkaListenerContainerFactory(
      ConcurrentKafkaListenerContainerFactoryConfigurer configurer) {
    var factory = new ConcurrentKafkaListenerContainerFactory<>();
    configurer.configure(factory, consumerFactory());

    factory.setCommonErrorHandler(new GlobalErrorHandler());

    return factory;
  }

对于正在使用更新版本的Spring-Boot 3.0.x的人来说，下面是基于@GarryRussel输入的实现：handleRecord（）已从Sping Boot 2.9中弃用，handleOne（）是其替代品。

factory.setCommonErrorHandler(new CommonErrorHandler() {
        @Override
        public boolean handleOne(Exception thrownException, ConsumerRecord<?, ?> record, Consumer<?, ?> consumer, MessageListenerContainer container) {
            return CommonErrorHandler.super.handleOne(thrownException, record, consumer, container);
        }

        @Override
        public void handleOtherException(Exception thrownException, Consumer<?, ?> consumer, MessageListenerContainer container, boolean batchListener) {
            CommonErrorHandler.super.handleOtherException(thrownException, consumer, container, batchListener);
        }
    });