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

import org.apache.kafka.clients.consumer.Consumer;
import org.springframework.kafka.listener.ConsumerAwareErrorHandler;
import org.springframework.kafka.listener.MessageListenerContainer;
import org.springframework.kafka.listener.MessageListener;
import org.springframework.kafka.support.Acknowledgment;

public class CustomErrorHandler implements ConsumerAwareErrorHandler {

    @Override
    public void handle(Exception thrownException, ConsumerRecord<?, ?> data, Consumer<?, ?> consumer) {
        // 自定义错误处理逻辑
        System.err.println("Error processing message: " + thrownException.getMessage());

        // 获取当前的 MessageListenerContainer
        MessageListenerContainer container = consumer.subscription();
        if (container != null) {
            // 获取当前的 Acknowledgment 对象
            Acknowledgment acknowledgment = container.getAcknowledgment();
            if (acknowledgment != null) {
                // 手动提交偏移量
                acknowledgment.acknowledge();
            }
        }
    }
}

// 配置 Kafka 消费者
@Bean
public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory =
            new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory());
    factory.setErrorHandler(new CustomErrorHandler());
    return factory;
}