如何在使用并发时使用ConsumerAwareErrorHandler提交偏移量？

import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.listener.ConsumerAwareErrorHandler;
import org.springframework.kafka.listener.KafkaListenerErrorHandler;
import org.springframework.kafka.listener.ListenerExecutionFailedException;
import org.springframework.kafka.listener.MessageListenerContainer;
import org.springframework.kafka.listener.SeekToCurrentErrorHandler;
import org.springframework.kafka.listener.SeekToCurrentErrorHandler.SeekToCurrentErrorHandlerLogger;
import org.springframework.kafka.listener.SeekToCurrentErrorHandler.SeekUtils;
import org.springframework.kafka.listener.SeekToCurrentErrorHandler.SeekUtils.SeekPosition;
import org.springframework.kafka.support.Acknowledgment;
import org.springframework.kafka.support.ConsumerRecordMetadata;
import org.springframework.kafka.support.KafkaHeaders;
import org.springframework.kafka.support.serializer.DeserializationException;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
import org.springframework.util.backoff.BackOff;
import org.springframework.util.backoff.FixedBackOff;

public class CustomErrorHandler implements ConsumerAwareErrorHandler {

    private final SeekToCurrentErrorHandler delegate;

    public CustomErrorHandler() {
        this.delegate = new SeekToCurrentErrorHandler();
    }

    @Override
    public void handle(Exception thrownException, ConsumerRecord<?, ?> record, Consumer<?, ?> consumer,
            MessageListenerContainer container) {
        // 处理异常
        // ...

        // 提交偏移量
        if (record != null && consumer != null) {
            // 使用ConsumerSeekCallback接口的seek方法提交偏移量
            container.seekToCurrentErrorHandler().handle(thrownException, record, consumer, container);
        }
    }
}