如何在spring kafka异常处理程序中获取原始记录

public class CustomErrorHandler implements ErrorHandler {
    @Override
    public void handle(Exception thrownException, ConsumerRecord<?, ?> record) {
        // 处理异常的逻辑
        // 获取原始记录的相关信息
        String topic = record.topic();
        int partition = record.partition();
        long offset = record.offset();
        Object key = record.key();
        Object value = record.value();
        
        // 具体的异常处理逻辑
        // ...
    }
}

@Configuration
@EnableKafka
public class KafkaConfig {

    @Bean
    public ConsumerFactory<?, ?> consumerFactory() {
        // 配置ConsumerFactory
        // ...
    }

    @Bean
    public ConcurrentKafkaListenerContainerFactory<?, ?> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<?, ?> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory());
        
        // 配置异常处理程序
        factory.setErrorHandler(new CustomErrorHandler());
        
        return factory;
    }
}