我刚开始使用SpringKafka2.6.4。我创建了按批轮询消息的消费者工厂：

@Bean
public ConcurrentKafkaListenerContainerFactory<String, String>
            kafkaListenerContainerFactory(MeterRegistry meterRegistry) {
    ConcurrentKafkaListenerContainerFactory<String, String> factory =
        new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory());
    factory.setConcurrency(kafkaProperties.getTopicConcurrency());
    factory.setBatchListener(true);
    factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.BATCH);
    return factory;
}

现在，我想定义适当的错误处理程序，使使用者停留在失败的记录上，而不是轮询下一批。
我应该使用哪个错误处理程序？
谢谢。