当第一次重试抛出的异常与第二次重试抛出的异常不同时，如何在Spring Kafka消费者中重置重试次数？

public class CustomSeekToCurrentErrorHandler extends SeekToCurrentErrorHandler {

    @Override
    protected long determineRetryTime(ConsumerRecord<?, ?> record, Exception exception, ListenerExecutionFailedException exception1) {
        // 获取第一次重试抛出的异常
        Exception firstRetryException = (Exception) record.headers().lastHeader("firstRetryException").value();

        // 获取第二次重试抛出的异常
        Exception secondRetryException = (Exception) record.headers().lastHeader("secondRetryException").value();

        // 判断第一次重试抛出的异常与第二次重试抛出的异常是否相同
        if (!firstRetryException.getClass().equals(secondRetryException.getClass())) {
            // 重置重试次数
            clearThreadState();
        }

        // 返回重试时间间隔
        return super.determineRetryTime(record, exception, exception1);
    }
}

@Bean
public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory());
    factory.setErrorHandler(new CustomSeekToCurrentErrorHandler());
    return factory;
}